Thank you for your suggestion. I understood that the operation must be done in 2 steps.
The first is GenerateUploadUrl and then upload.
I think I managed to do the first step but then it fails when I send the file.
I have upload url and parameters.
Could you help me understand where the error is in the second step?
This is my code:
public async Task<string> GenerateUploadUrlAndUploadFile(string fileName, byte[] fileContent)
{
var uploadDetails = await GenerateUploadUrl(fileName, fileContent.Length);
if (string.IsNullOrEmpty(uploadDetails))
{
throw new Exception("Unable to generate upload URL.");
}
// Estrai i dettagli di caricamento dalla risposta
var uploadData = JsonConvert.DeserializeObject<JObject>(uploadDetails);
var uploadUrl = uploadData["data"]["stagedUploadsCreate"]["stagedTargets"][0]["url"].ToString();
var uploadParameters = uploadData["data"]["stagedUploadsCreate"]["stagedTargets"][0]["parameters"].ToObject<List<Dictionary<string, string>>>();
// Prepara la richiesta di caricamento
var requestMessage = new HttpRequestMessage(HttpMethod.Post, uploadUrl)
{
Content = new ByteArrayContent(fileContent)
};
// Imposta i parametri come header della richiesta
foreach (var parameter in uploadParameters)
{
requestMessage.Headers.TryAddWithoutValidation(parameter["name"], parameter["value"]);
}
// Esegui la richiesta di caricamento
var uploadResult = await _httpClient.SendAsync(requestMessage);
if (!uploadResult.IsSuccessStatusCode)
{
Console.WriteLine("Failed to upload file. Response content: " + responseContent);
throw new Exception("Failed to upload file. Status: " + uploadResult.StatusCode);
}
// Restituisci l'URL della risorsa caricata o un'altra informazione rilevante
return uploadResult.Headers.Location.ToString();
}
private async Task<string> GenerateUploadUrl(string fileName, long fileSize)
{
var mutation = @"
mutation stagedUploadsCreate($input: [StagedUploadInput!]!) {
stagedUploadsCreate(input: $input) {
stagedTargets {
parameters {
name
value
}
url
resourceUrl
}
}
}";
var variables = new
{
input = new[]
{
new
{
resource = "FILE",
filename = fileName,
mimeType = "application/pdf",
httpMethod = "POST",
fileSize = fileSize.ToString()
}
}
};
var requestBody = new
{
query = mutation,
variables = variables
};
var requestContent = new StringContent(JsonConvert.SerializeObject(requestBody), Encoding.UTF8, "application/json");
_httpClient.DefaultRequestHeaders.Clear();
_httpClient.DefaultRequestHeaders.Add("X-Shopify-Access-Token", _accessToken);
var response = await _httpClient.PostAsync($"https://{_shopifyStoreUrl}/admin/api/2023-10/graphql.json", requestContent);
var responseString = await response.Content.ReadAsStringAsync();
return response.IsSuccessStatusCode ? responseString : null;
}
