remove unused packages from provisioner

provisioner/integrations/state/s3/s3.go

@@ -1,102 +0,0 @@
-package s3
-
-// type Client struct {
-// 	client *s3.S3
-// 	bucket string
-// }
-
-// var LOCAL_RUN string
-// var ENCRYPT_KEY string
-
-// func init() {
-// 	LOCAL_RUN = os.Getenv("LOCAL_RUN")
-
-// 	ENCRYPT_KEY = os.Getenv("ENCRYPT_KEY")
-
-// 	if ENCRYPT_KEY == "" {
-// 		if LOCAL_RUN == "true" {
-// 			ENCRYPT_KEY = "the-key-has-to-be-32-bytes-long!"
-// 		} else {
-// 			panic("no encryption key set for storage")
-// 		}
-// 	}
-// }
-
-// func NewS3Client(bucket string) *Client {
-// 	var sess *session.Session
-// 	var err error
-
-// 	if LOCAL_RUN == "true" {
-// 		sess, err = session.NewSession(&aws.Config{
-// 			Region:   aws.String("us-east-1"),
-// 			Endpoint: aws.String("localhost.localstack.cloud:4566"),
-// 		})
-// 	} else {
-// 		sess, err = session.NewSession()
-// 		if err != nil {
-// 			log.Fatal("cannot create aws session", err.Error())
-// 		}
-// 	}
-
-// 	return &Client{
-// 		client: s3.New(sess),
-// 		bucket: bucket,
-// 	}
-// }
-
-// func (s *Client) GetObject(org, filename string) (io.ReadCloser, error) {
-// 	log.Println(org, filename)
-// 	output, err := s.client.GetObject(&s3.GetObjectInput{
-// 		Bucket: &s.bucket,
-// 		Key:    aws.String(fmt.Sprintf("%s/%s", org, filename)),
-// 	})
-
-// 	if err != nil {
-// 		return nil, err
-// 	}
-
-// 	var encryptedData bytes.Buffer
-// 	_, err = encryptedData.ReadFrom(output.Body)
-// 	if err != nil {
-// 		return nil, err
-// 	}
-
-// 	data, err := encryption.Decrypt(encryptedData.Bytes(), []byte(ENCRYPT_KEY))
-// 	if err != nil {
-// 		return nil, err
-// 	}
-
-// 	return io.NopCloser(bytes.NewReader(data)), nil
-// }
-
-// func (s *Client) PutObject(org, filename string, body []byte) error {
-// 	encryptedBody, err := encryption.Encrypt(body, []byte(ENCRYPT_KEY))
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	_, err = s.client.PutObject(&s3.PutObjectInput{
-// 		Body:   aws.ReadSeekCloser(bytes.NewReader(encryptedBody)),
-// 		Bucket: &s.bucket,
-// 		Key:    aws.String(fmt.Sprintf("%s/%s", org, filename)),
-// 	})
-
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	return nil
-// }
-
-// func (s *Client) DeleteObject(org, filename string) error {
-// 	_, err := s.client.DeleteObject(&s3.DeleteObjectInput{
-// 		Bucket: &s.bucket,
-// 		Key:    aws.String(fmt.Sprintf("%s/%s", org, filename)),
-// 	})
-
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	return nil
-// }

provisioner/processor/resource.go

@@ -1,119 +0,0 @@
-package processor
-
-// type EventProcessor struct {}
-
-// type Event struct {
-// 	OrgID string
-// 	*types.TFLogLine
-// }
-
-// func (e *EventProcessor) GetFileData(ordID string) (bytes.Buffer, error) {
-// 	var data bytes.Buffer
-
-// 	reader, err := e.client.GetObject(ordID, "desired.json")
-// 	if err != nil {
-// 		return data, err
-// 	}
-
-// 	_, err = data.ReadFrom(reader)
-// 	if err != nil {
-// 		return data, err
-// 	}
-
-// 	return data, nil
-// }
-
-// func (e *EventProcessor) WriteFileData(orgID string, data []byte) error {
-// 	err := e.client.PutObject(orgID, "desired.json", data)
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	return nil
-// }
-
-// func (e *EventProcessor) MarkErroredResourceInDesiredState(event *Event) error {
-// 	fileData, err := e.GetFileData(event.OrgID)
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	var desiredState types.DesiredTFState
-// 	err = json.Unmarshal(fileData.Bytes(), &desiredState)
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	// find the correct matching resource name in the desired state
-// 	for i, resource := range desiredState {
-// 		if resource.Resource == event.Hook.Resource.Resource {
-// 			// add error message to this resource
-// 			resource.Errored.ErroredOut = true
-// 			desiredState[i] = resource
-
-// 			// write back the file
-// 			data, err := json.Marshal(desiredState)
-// 			if err != nil {
-// 				return err
-// 			}
-
-// 			return e.client.PutObject(event.OrgID, "desired.json", data)
-// 		}
-// 	}
-
-// 	return fmt.Errorf("cannot find a matching resource entry")
-// }
-
-// func (e *EventProcessor) AddErrorContextToResource(event *Event) error {
-// 	fileData, err := e.GetFileData(event.OrgID)
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	var desiredState types.DesiredTFState
-// 	err = json.Unmarshal(fileData.Bytes(), &desiredState)
-// 	if err != nil {
-// 		return err
-// 	}
-
-// 	// find and add error context to the matching resource
-// 	for i, resource := range desiredState {
-// 		if event.Diagnostic.Address == resource.Resource {
-// 			resource.Errored.ErrorSummary = event.Diagnostic.Summary
-// 			desiredState[i] = resource
-
-// 			// write back
-// 			data, err := json.Marshal(desiredState)
-// 			if err != nil {
-// 				return err
-// 			}
-
-// 			return e.client.PutObject(event.OrgID, "desired.json", data)
-// 		}
-// 	}
-
-// 	return fmt.Errorf("cannot find a matching resource entry")
-// }
-
-// func (e *EventProcessor) Filter(event *Event) error {
-// 	switch event.Type {
-// 	case types.ApplyErrored:
-// 		return e.MarkErroredResourceInDesiredState(event)
-// 	case types.Diagnostic:
-// 		if event.Level == "error" {
-// 			return e.AddErrorContextToResource(event)
-// 		}
-
-// 		return nil
-// 	default:
-// 		return nil
-// 	}
-// }
-
-// func NewEventProcessor() *EventProcessor {
-// 	BUCKET := os.Getenv("BUCKET")
-
-// 	return &EventProcessor{
-// 		client: s3.NewS3Client(BUCKET),
-// 	}
-// }