graphql - 如何使用 nestjs-graphql-fastify 服务器上传文件以及如何测试该功能？

Question

我很难将 .csv 文件上传到 nestjs-graphql-fastify 服务器。尝试了以下代码:

  @Mutation(() => Boolean)
  async createUsers(
    @Args({ name: 'file', type: () => GraphQLUpload })
    { createReadStream, filename }: FileUpload,
  ): Promise<boolean> {
    try {
      // backend logic . . .
    } catch {
      return false;
    }
    return true;
  }

但是我在使用 postman 进行测试时得到的只是这个响应:

{
    "statusCode": 415,
    "code": "FST_ERR_CTP_INVALID_MEDIA_TYPE",
    "error": "Unsupported Media Type",
    "message": "Unsupported Media Type: multipart/form-data; boundary=--------------------------511769018912715357993837"
}

使用代码优先方法进行开发。

更新:尝试使用 fastify-multipart 但问题仍然存在。改变的是 postman 的回应:

POST body missing, invalid Content-Type, or JSON object has no keys.

Answer 1

在 Nestjs discord channel 上找到了一些答案。

您必须进行以下更改:

主要.ts

async function bootstrap() {
  const adapter = new FastifyAdapter();
  const fastify = adapter.getInstance();

  fastify.addContentTypeParser('multipart', (request, done) => {
    request.isMultipart = true;
    done();
  });
  fastify.addHook('preValidation', async function (request: any, reply) {
    if (!request.raw.isMultipart) {
      return;
    }

    request.body = await processRequest(request.raw, reply.raw);
  });

  const app = await NestFactory.create<NestFastifyApplication>(
    AppModule,
    adapter,
  );


  await app.listen(apiServerPort, apiServerHost);
}

bootstrap();

上传.标量.ts

import { Scalar } from '@nestjs/graphql';
import { GraphQLUpload } from 'graphql-upload';

@Scalar('Upload')
export class UploadGraphQLScalar {
  protected parseValue(value) {
    return GraphQLUpload.parseValue(value);
  }

  protected serialize(value) {
    return GraphQLUpload.serialize(value);
  }

  protected parseLiteral(ast) {
    return GraphQLUpload.parseLiteral(ast, ast.value);
  }
}

用户.resolver.ts

  @Mutation(() => CreateUsersOutput, {name: 'createUsers'})
  async createUsers(
    @Args('input', new ValidationPipe()) input: CreateUsersInput,
    @ReqUser() reqUser: RequestUser,
  ): Promise<CreateUsersOutput> {
    return this.usersService.createUsers(input, reqUser);
  }

创建共享.input.ts

@InputType()
export class DataObject {
  @Field(() => UploadGraphQLScalar)
  @Exclude()
  public readonly csv?: Promise<FileUpload>;
}

@InputType()
@ArgsType()
export class CreateUsersInput {
  @Field(() => DataObject)
  public readonly data: DataObject;
}

另外，我想提一下你不应该使用全局验证管道(在我的例子中它们使文件不可读)

  // app.useGlobalPipes(new ValidationPipe({ transform: true }));