Lambda service impl (#104)

Author: goncalo-rodrigues

api/converter/converter.go

@@ -504,3 +504,38 @@ func (v KubernetesNodePoolConverter) ConvertToMultyResource(resourceId string, m
 		ImplicitlyCreated: false,
 	}, nil
 }
+
+type LambdaConverter struct {
+}
+
+func (v LambdaConverter) NewArg() proto.Message {
+	return &resources.CloudSpecificRouteTableArgs{}
+}
+
+func (v LambdaConverter) ConvertToMultyResource(resourceId string, m proto.Message, otherResources map[string]common_resources.CloudSpecificResource) (common_resources.CloudSpecificResource, error) {
+	arg := m.(*resources.CloudSpecificLambdaArgs)
+	c := cloud_providers.CloudProvider(strings.ToLower(arg.CommonParameters.CloudProvider.String()))
+	l := types.Lambda{
+		CommonResourceParams: &common_resources.CommonResourceParams{
+			ResourceId:      resourceId,
+			ResourceGroupId: arg.CommonParameters.ResourceGroupId,
+			Location:        strings.ToLower(arg.CommonParameters.Location.String()),
+			Clouds:          []string{string(c)},
+		},
+		FunctionName: arg.Name,
+		Runtime:      arg.Runtime,
+	}
+
+	if o, ok := otherResources[common_resources.GetResourceIdForCloud(arg.SourceCodeObjectId, c)]; ok {
+		// Connect to vn in the same cloud
+		l.SourceCodeObject = o.Resource.(*types.ObjectStorageObject)
+	} else {
+		return common_resources.CloudSpecificResource{}, fmt.Errorf("object with id %s not found in %s", arg.SourceCodeObjectId, c)
+	}
+
+	return common_resources.CloudSpecificResource{
+		Cloud:             c,
+		Resource:          &l,
+		ImplicitlyCreated: false,
+	}, nil
+}

api/deploy/deploy.go

@@ -56,7 +56,7 @@ func Deploy(c *config.Config, resourceId string) error {
 			if err != nil {
 				return err
 			}
-		} else if resourceMessage.MessageIs(&resources.NetworkSecurityGroupResource{}) {
+		} else if resourceMessage.MessageIs(&resources.CloudSpecificNetworkSecurityGroupArgs{}) {
 			err := addMultyResource(r, translated, &converter.NetworkSecurityGroupConverter{})
 			if err != nil {
 				return err
@@ -91,6 +91,11 @@ func Deploy(c *config.Config, resourceId string) error {
 			if err != nil {
 				return err
 			}
+		} else if resourceMessage.MessageIs(&resources.CloudSpecificLambdaArgs{}) {
+			err := addMultyResource(r, translated, &converter.LambdaConverter{})
+			if err != nil {
+				return err
+			}
 		} else {
 			return fmt.Errorf("unknown resource type %s", resourceMessage.MessageName())
 		}

api/proto/multy_service.pb.go

@@ -7,6 +7,7 @@ option java_outer_classname = "MultyProto";
 
 import "api/proto/resources/virtual_network.proto";
 import "api/proto/resources/public_ip.proto";
+import "api/proto/resources/lambda.proto";
 import "api/proto/resources/kubernetes_cluster.proto";
 import "api/proto/resources/kubernetes_node_pool.proto";
 import "api/proto/resources/object_storage.proto";
@@ -81,4 +82,9 @@ service MultyResourceService {
   rpc ReadKubernetesNodePool (resources.ReadKubernetesNodePoolRequest) returns (resources.KubernetesNodePoolResource) {}
   rpc UpdateKubernetesNodePool (resources.UpdateKubernetesNodePoolRequest) returns (resources.KubernetesNodePoolResource) {}
   rpc DeleteKubernetesNodePool (resources.DeleteKubernetesNodePoolRequest) returns (common.Empty) {}
+
+  rpc CreateLambda (resources.CreateLambdaRequest) returns (resources.LambdaResource) {}
+  rpc ReadLambda (resources.ReadLambdaRequest) returns (resources.LambdaResource) {}
+  rpc UpdateLambda (resources.UpdateLambdaRequest) returns (resources.LambdaResource) {}
+  rpc DeleteLambda (resources.DeleteLambdaRequest) returns (common.Empty) {}
 }