main.go

package main

import (
	"context"
	"errors"
	"github.com/aws/aws-lambda-go/events"
	"github.com/aws/aws-lambda-go/lambda"
	"jira-timesheet/jira"
	odoo "jira-timesheet/odoo"
	"jira-timesheet/teamsnotifier"
	"jira-timesheet/utils"
	"os"
	"reflect"
	"strings"
)

func ErrorResponse(request jira.Request, e error) events.APIGatewayProxyResponse {
	var blank = jira.Request{}

	if !reflect.DeepEqual(request, blank) {
		teamsnotifier.Notify(teamsnotifier.NewOdooError(request, e))
	} else {
		teamsnotifier.Notify(teamsnotifier.NewJiraError(e))

	}

	return events.APIGatewayProxyResponse{
		StatusCode: 500,
		Body:       e.Error(),
	}
}

func preventOdooCrash(request jira.Request){
	if !odooCredsOk{
		teamsnotifier.Notify(teamsnotifier.NewOdooError(request, errors.New("Odoo connection error , please check your creds")))
	}
}

var odooCredsOk = false


func Handler(ctx context.Context, request events.APIGatewayProxyRequest) (events.APIGatewayProxyResponse, error) {


	var timesheetCodeField = os.Getenv("JIRA_TIMESHEET_FIELD")
	if timesheetCodeField == "" {
		timesheetCodeField = "customfield_10101" //Default value
	}

	var body = strings.ReplaceAll(request.Body, timesheetCodeField, "odoo_timesheet_code")

	jiraRequest, err := jira.NewWorklogRequest(body)
	if err != nil {
		return ErrorResponse(jira.Request{}, err), nil
	}

	var odoo_whitelist = os.Getenv("ODOO_WHITELIST")
	if  odoo_whitelist != "" {
		var white_projects = strings.Split(odoo_whitelist,",")
		if !utils.SliceContains(white_projects, jiraRequest.Issue.Fields.TimesheetCode) {
			return ErrorResponse(jiraRequest, errors.New(jiraRequest.Issue.Fields.TimesheetCode+" is not in the whitelist ( "+odoo_whitelist+")")), nil
		}
	}

	var users_whitelist = os.Getenv("USERS_WHITELIST")
	if users_whitelist != "" {
		var white_users = strings.Split(users_whitelist,",")
		if !utils.SliceContains(white_users, jiraRequest.User.Email) {
			return ErrorResponse(jiraRequest, errors.New(jiraRequest.User.Email+" is not in the whitelist ( "+users_whitelist+")")), nil

		}

	}



	var lastWorklog = jiraRequest.GetLastWorklog()

	defer preventOdooCrash(jiraRequest) ////odoo panic if authentication fails, we have to notify user of bad creds

	if jiraRequest.Issue.Fields.TimesheetCode == "" {
		return ErrorResponse(jiraRequest, errors.New("Can't proceed request with not any timesheet code !")), nil
	}

	err = odoo.CreateTimesheetLine(
		jiraRequest.Issue.Key,
		jiraRequest.User.Email,
		jiraRequest.Issue.Fields.TimesheetCode,
		lastWorklog.GetHours(),
		lastWorklog.GetDate())
	odooCredsOk = true

	if err != nil {
		return ErrorResponse(jiraRequest, err), nil
	}

	teamsnotifier.Notify(teamsnotifier.NewSuccess(jiraRequest))
	return events.APIGatewayProxyResponse{
		StatusCode: 200,
		Body:       "OK",
	}, nil


}


func main() {
	lambda.Start(Handler)
}