added some logging

Author: abhishek

get-object/src/main/java/io/fnproject/example/ObjectStoreGetFunction.java

@@ -21,10 +21,10 @@ public class ObjectStoreGetFunction {
  private ObjectStorage objStoreClient = null;
 
  public ObjectStoreGetFunction() {
- System.err.println("Inside ObjectStoreGetFunction ctor()");
+ System.err.println("Inside ObjectStoreGetFunction constructor");
 
  try {
- String privateKey = System.getenv().getOrDefault("OCI_PRIVATE_KEY_FILE_NAME", "oci_api_key.pem");
+ String privateKey = System.getenv().get("OCI_PRIVATE_KEY_FILE_NAME");
  System.err.println("Private key " + privateKey);
  Supplier<InputStream> privateKeySupplier = () -> {
  InputStream is = null;
@@ -48,14 +48,11 @@ public ObjectStoreGetFunction() {
  .privateKeySupplier(privateKeySupplier)
  .build();
 
- System.err.println("AuthenticationDetailsProvider setup..");
-
  objStoreClient = new ObjectStorageClient(provider);
  objStoreClient.setRegion(System.getenv().get("REGION"));
 
- System.err.println("ObjectStorage client setup");
  } catch (Throwable ex) {
- System.err.println("Error occurred in ObjectStoreListFunction ctor " + ex.getMessage());
+ System.err.println("Error occurred in ObjectStoreListFunction constructor " + ex.getMessage());
 
  }
  }
@@ -92,7 +89,7 @@ public String handle(GetObjectInfo objectInfo) {
  }
  try {
 
- String nameSpace = System.getenv().getOrDefault("NAMESPACE", "test-namespace");
+ String nameSpace = System.getenv().get("NAMESPACE");
 
  GetObjectRequest gor = GetObjectRequest.builder()
  .namespaceName(nameSpace)
@@ -104,6 +101,8 @@ public String handle(GetObjectInfo objectInfo) {
  result = new BufferedReader(new InputStreamReader(response.getInputStream()))
  .lines().collect(Collectors.joining("\n"));
 
+ System.err.println("Finished reading content for object " + objectInfo.getName());
+
  } catch (Exception e) {
  System.err.println("Error fetching object " + e.getMessage());
  result = "Error fetching object " + e.getMessage();

list-objects/src/main/java/io/fnproject/example/ObjectStoreListFunction.java

@@ -21,9 +21,9 @@ public class ObjectStoreListFunction {
  private ObjectStorage objStoreClient = null;
 
  public ObjectStoreListFunction() {
- System.err.println("Inside ObjectStoreListFunction ctor");
+ System.err.println("Inside ObjectStoreListFunction constructor");
  try {
- String privateKey = System.getenv().getOrDefault("OCI_PRIVATE_KEY_FILE_NAME", "oci_api_key.pem");
+ String privateKey = System.getenv().get("OCI_PRIVATE_KEY_FILE_NAME");
  System.err.println("Private key " + privateKey);
 
  Supplier<InputStream> privateKeySupplier = () -> {
@@ -48,14 +48,11 @@ public ObjectStoreListFunction() {
  .privateKeySupplier(privateKeySupplier)
  .build();
 
- System.err.println("AuthenticationDetailsProvider setup");
-
  objStoreClient = new ObjectStorageClient(provider);
  objStoreClient.setRegion(System.getenv().get("REGION"));
 
- System.err.println("ObjectStorage client setup");
  } catch (Exception ex) {
- System.err.println("Error occurred in ObjectStoreListFunction ctor " + ex.getMessage());
+ System.err.println("Error occurred in ObjectStoreListFunction constructor " + ex.getMessage());
  }
  }
 
@@ -67,7 +64,7 @@ public List<String> handle(String bucketName) {
 
  List<String> objNames = null;
  try {
- String nameSpace = System.getenv().getOrDefault("NAMESPACE", "test-namespace");
+ String nameSpace = System.getenv().get("NAMESPACE");
 
  ListObjectsRequest lor = ListObjectsRequest.builder()
  .namespaceName(nameSpace)
@@ -80,6 +77,8 @@ public List<String> handle(String bucketName) {
  .map((objSummary) -> objSummary.getName())
  .collect(Collectors.toList());
 
+ System.err.println("Got list of objects in bucket " + bucketName);
+
  } catch (Exception e) {
  System.err.println("Error invoking object store API " + e.getMessage());
  }

put-object/src/main/java/io/fnproject/example/ObjectStorePutFunction.java

@@ -20,9 +20,9 @@ public class ObjectStorePutFunction {
  private ObjectStorage objStoreClient = null;
 
  public ObjectStorePutFunction() {
- System.err.println("Inside ObjectStorePutFunction ctor");
+ System.err.println("Inside ObjectStorePutFunction constructor");
  try {
- String privateKey = System.getenv().getOrDefault("OCI_PRIVATE_KEY_FILE_NAME", "oci_api_key.pem");
+ String privateKey = System.getenv().get("OCI_PRIVATE_KEY_FILE_NAME");
  System.err.println("Private key " + privateKey);
  Supplier<InputStream> privateKeySupplier = () -> {
  InputStream is = null;
@@ -46,14 +46,11 @@ public ObjectStorePutFunction() {
  .privateKeySupplier(privateKeySupplier)
  .build();
 
- System.err.println("AuthenticationDetailsProvider setup");
-
  objStoreClient = new ObjectStorageClient(provider);
  objStoreClient.setRegion(System.getenv().get("REGION"));
 
- System.err.println("ObjectStorage client setup");
  } catch (Exception ex) {
- System.err.println("Error occurred in ObjectStorePutFunction ctor " + ex.getMessage());
+ System.err.println("Error occurred in ObjectStorePutFunction constructor " + ex.getMessage());
  }
  }
 
@@ -92,7 +89,6 @@ public void setContent(String content) {
 
  }
 
-
  public String handle(ObjectInfo objectInfo) {
  System.err.println("Inside ObjectStorePutFunction/handle");
  String result = "FAILED";
@@ -102,7 +98,7 @@ public String handle(ObjectInfo objectInfo) {
  }
  try {
 
- String nameSpace = System.getenv().getOrDefault("NAMESPACE", "test-namespace");
+ String nameSpace = System.getenv().get("NAMESPACE");
 
  PutObjectRequest por = PutObjectRequest.builder()
  .namespaceName(nameSpace)
@@ -112,7 +108,8 @@ public String handle(ObjectInfo objectInfo) {
  .build();
 
  PutObjectResponse poResp = objStoreClient.putObject(por);
- result = "OPC ID for upload operation for object " + objectInfo.name + " - " + poResp.getOpcRequestId();
+ result = "Successfully submitted Put request for object " + objectInfo.name + "in bucket " +objectInfo.bucketName + ". OPC reuquest ID is " + poResp.getOpcRequestId();
+ System.err.println(result);
 
  } catch (Exception e) {
  System.err.println("Error invoking object store API " + e.getMessage());