-
Notifications
You must be signed in to change notification settings - Fork 123
/
Copy pathCopyObjects.cs
43 lines (34 loc) · 1.53 KB
/
CopyObjects.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
using Fnproject.Fn.Fdk;
using System.Runtime.CompilerServices;
using System.Collections.Generic;
using System;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using Newtonsoft.Json;
using Oci.ObjectstorageService;
using Oci.ObjectstorageService.Models;
namespace CopyObjects
{
class Function
{
public string function_handler(String input)
{
Dictionary<string, List<ObjectDetails>> output = new Dictionary<string, List<ObjectDetails>>();
var object_details_list = new List<ObjectDetails>();
dynamic event_json = JsonConvert.DeserializeObject(input);
string src_bucketName = event_json.data.additionalDetails["bucketName"];
string dest_bucketName = event_json.data.additionalDetails["bucketName"] + "_IMMUTABLE";
string namespaceName = event_json.data.additionalDetails["namespace"];
string objectName = event_json.data.resourceName;
ObjectStorageClient client = ObjectStorageClientHelper.GetObjectStorageClient();
Task<string> object_str = CopyObjectsHelper.CopyObject(client, src_bucketName, dest_bucketName, namespaceName, objectName);
var object_detail = new ObjectDetails();
object_detail.result = object_str.Result;
object_details_list.Add(object_detail);
output.Add("results", object_details_list);
return System.Text.Json.JsonSerializer.Serialize(output);
}
static void Main(string[] args) { Fdk.Handle(args[0]); }
}
}