使用 graphql-request 代理对 graphql api 的多部分请求
Proxy multipart request to graphql api using graphql-request
我有一个 nodejs express 应用程序,用作客户端应用程序和 graphql 之间的代理 api。 graphql api 实现了 graphql-multipart-request-spec。我正在使用 graphql-request 包来查询它。
代理应用程序使用 nestjs 和 multer 进行上传。
根据 graphql-request 文档,您可以像这样上传文件
const UploadUserAvatar = gql`
mutation uploadUserAvatar($userId: Int!, $file: Upload!) {
updateUser(id: $userId, input: { avatar: $file })
}
`
request('/api/graphql', UploadUserAvatar, {
userId: 1,
file: createReadStream('./avatar.img'),
})
但这意味着上传的文件已经保存到文件系统中。是否可以使用文件的缓冲区做同样的事情?
我尝试将缓冲区转换为 ReadableStream,如下所示:
const readable = new Readable()
readable._read = () => {} // _read is required but you can noop it
readable.push(file.buffer)
readable.push(null)
await request('/api/graphql', UploadUserAvatar, {
userId: 1,
file: readable,
})
但是graphqlapireturns出现如下错误:
Unexpected end of multipart data
我遇到了类似的问题,我使用 form-data
包解决了它。
对我有用的灵魂:
import FormData from "form-data";
function uploadUserAvatar(userId: string, readable) {
const requestBody = new FormData();
requestBody.append('operations', JSON.stringify({
query: UploadUserAvatar,
variables: { userId }
}));
requestBody.append('map', JSON.stringify({
0: ['variables.file']
}));
requestBody.append('0', readable);
return new Promise((resolve, reject) => {
requestBody.submit('http://endpoint/api/graphql', (err, res) => {
if (err) {
reject(err);
} else {
let body = '';
res.on('readable', () => {
body += res.read();
});
res.on('end', () => {
resolve(JSON.parse(body));
});
}
});
});
}
希望它也能解决你的问题。
我有一个 nodejs express 应用程序,用作客户端应用程序和 graphql 之间的代理 api。 graphql api 实现了 graphql-multipart-request-spec。我正在使用 graphql-request 包来查询它。 代理应用程序使用 nestjs 和 multer 进行上传。
根据 graphql-request 文档,您可以像这样上传文件
const UploadUserAvatar = gql`
mutation uploadUserAvatar($userId: Int!, $file: Upload!) {
updateUser(id: $userId, input: { avatar: $file })
}
`
request('/api/graphql', UploadUserAvatar, {
userId: 1,
file: createReadStream('./avatar.img'),
})
但这意味着上传的文件已经保存到文件系统中。是否可以使用文件的缓冲区做同样的事情?
我尝试将缓冲区转换为 ReadableStream,如下所示:
const readable = new Readable()
readable._read = () => {} // _read is required but you can noop it
readable.push(file.buffer)
readable.push(null)
await request('/api/graphql', UploadUserAvatar, {
userId: 1,
file: readable,
})
但是graphqlapireturns出现如下错误:
Unexpected end of multipart data
我遇到了类似的问题,我使用 form-data
包解决了它。
对我有用的灵魂:
import FormData from "form-data";
function uploadUserAvatar(userId: string, readable) {
const requestBody = new FormData();
requestBody.append('operations', JSON.stringify({
query: UploadUserAvatar,
variables: { userId }
}));
requestBody.append('map', JSON.stringify({
0: ['variables.file']
}));
requestBody.append('0', readable);
return new Promise((resolve, reject) => {
requestBody.submit('http://endpoint/api/graphql', (err, res) => {
if (err) {
reject(err);
} else {
let body = '';
res.on('readable', () => {
body += res.read();
});
res.on('end', () => {
resolve(JSON.parse(body));
});
}
});
});
}
希望它也能解决你的问题。