import { Crud, BaseController } from '@aipeli/midway-crud';
import { Config, Get, Inject } from '@midwayjs/decorator';
import * as qiniu from 'qiniu'
import { KodoService } from './kodo_manager';

@Crud('/kodo')
export class KodoUploadController extends BaseController {
  @Inject()
  kodo: KodoService;
  @Inject()
  baseDir: string;
  @Config('kodo')
  kodoConfig: Record<string, string>;
  // http://127.0.0.1:7001/admin/shop/kodo/upload
  @Get('/upload')
  async upload() {
    console.log(this.baseDir, __dirname);

    //上传到七牛后保存的文件名
    // const key = 'upload/1.rar'
    const key = 'upload/midway-kodo-test.png'
    //要上传文件的本地路径
    // const filePath = __dirname + '/1.rar'
    const filePath = __dirname + '/midway-kodo-test.png'
    const putExtra = new qiniu.resume_up.PutExtra();
    // 如果指定了断点记录文件，那么下次会从指定的该文件尝试读取上次上传的进度，以实现断点续传
    // putExtra.resumeRecordFile = 'progress.log';
    //分片上传可指定 version 字段，v2 表示分片上传 v2 , 可自定义分片大小，此处设为 6MB
    putExtra.version = 'v2'
    putExtra.partSize = 6 * 1024 * 1024
    putExtra.progressCallback = function (uploadBytes, totalBytes) {
      console.log('progress:' + uploadBytes + '(' + totalBytes + ')');
    };
    try {
      const uploadResult = await this.kodo.ResumeUpPutExtra(putExtra).putFile(key, filePath, true)
      return { success: true, message: 'OK', data: uploadResult };
    }
    catch (error) {
      return { success: true, message: 'OK', data: error.error };
    }

  }
}

import { MidwayConfig } from '@midwayjs/core';

export default {
  kodo: {
    accessKey: '',
    secretkey: '',
    bucket: '',
    bucketDomain: '',
    metadata: ''
  }
} as MidwayConfig;

import { Configuration, App } from '@midwayjs/decorator';
import * as koa from '@midwayjs/koa';
import * as validate from '@midwayjs/validate';
import * as info from '@midwayjs/info';
import { join } from 'path';
import * as kodo from '@aipeli/midway-kodo';
@Configuration({
  imports: [
    koa,
    validate,
    kodo,
    {
      component: info,
      enabledEnvironment: ['local'],
    },
  ],
  importConfigs: [join(__dirname, './config')],
})
export class ContainerLifeCycle {
  @App()
  app: koa.Application;

  async onReady() {

  }
}