kind: role
version: v5
metadata:
  name: access-plugin
spec:
  allow:
    rules:
      - resources: ["access_request"]
        verbs: ["list", "read"]
      - resources: ["access_plugin_data"]
        verbs: ["update"]
---
kind: user
metadata:
  name: access-plugin
spec:
  roles: ["access-plugin"]
version: v2

kind: role
version: v7
metadata:
  name: access-plugin-impersonator
spec:
  allow:
    impersonate:
      roles:
      - access-plugin
      users:
      - access-plugin

kind: role
version: v7
metadata:
  name: editor-reviewer
spec:
  allow:
    review_requests:
      roles: ['editor']
---
kind: role
version: v7
metadata:
  name: editor-requester
spec:
  allow:
    request:
      roles: ['editor']
      thresholds:
        - approve: 1
          deny: 1

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

const (
	proxyAddr     string = "CHANGE ME"
	spreadSheetID string = "CHANGE ME"
)

https://docs.google.com/spreadsheets/d/SPREADHSEET_ID/edit#gid=0

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"context"

	sheets "google.golang.org/api/sheets/v4"

	"github.com/gravitational/teleport/api/client"
	"github.com/gravitational/teleport/api/types"
)

type AccessRequestPlugin struct {
	TeleportClient *client.Client
	EventHandler   interface {
		HandleEvent(ctx context.Context, event types.Event) error
	}
}

type googleSheetsClient struct {
	sheetsClient *sheets.SpreadsheetsService
}

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"fmt"
	"strings"

	sheets "google.golang.org/api/sheets/v4"

	"github.com/gravitational/teleport/api/types"
)

func stringPtr(s string) *string { return &s }

var requestStates = map[types.RequestState]string{
	types.RequestState_APPROVED: "APPROVED",
	types.RequestState_DENIED:   "DENIED",
	types.RequestState_PENDING:  "PENDING",
	types.RequestState_NONE:     "NONE",
}

func (g *googleSheetsClient) makeRowData(ar types.AccessRequest) *sheets.RowData {
	requestState := requestStates[ar.GetState()]

	viewLink := fmt.Sprintf(
		`=HYPERLINK("%v", "%v")`,
		"https://"+proxyAddr+"/web/requests/"+ar.GetName(),
		"View Access Request",
	)

	return &sheets.RowData{
		Values: []*sheets.CellData{
			&sheets.CellData{
				UserEnteredValue: &sheets.ExtendedValue{
					StringValue: stringPtr(ar.GetName()),
				},
			},
			&sheets.CellData{
				UserEnteredValue: &sheets.ExtendedValue{
					StringValue: stringPtr(ar.GetCreationTime().String()),
				},
			},
			&sheets.CellData{
				UserEnteredValue: &sheets.ExtendedValue{
					StringValue: stringPtr(ar.GetUser()),
				},
			},
			&sheets.CellData{
				UserEnteredValue: &sheets.ExtendedValue{
					StringValue: stringPtr(strings.Join(ar.GetRoles(), ",")),
				},
			},
			&sheets.CellData{
				UserEnteredValue: &sheets.ExtendedValue{
					StringValue: &requestState,
				},
			},
			&sheets.CellData{
				UserEnteredValue: &sheets.ExtendedValue{
					FormulaValue: &viewLink,
				},
			},
		},
	}
}

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"github.com/gravitational/trace"
	sheets "google.golang.org/api/sheets/v4"

	"github.com/gravitational/teleport/api/types"
)

func (g *googleSheetsClient) createRow(ar types.AccessRequest) error {
	row := g.makeRowData(ar)

	req := sheets.BatchUpdateSpreadsheetRequest{
		Requests: []*sheets.Request{
			{
				AppendCells: &sheets.AppendCellsRequest{

					Fields: "*",
					Rows: []*sheets.RowData{
						row,
					},
				},
			},
		},
	}

	resp, err := g.sheetsClient.BatchUpdate(spreadSheetID, &req).Do()
	if err != nil {
		return trace.Wrap(err)
	}

	if resp.HTTPStatusCode == 201 || resp.HTTPStatusCode == 200 {
		return nil
	}

	return trace.Errorf("Unexpected response code creating a row: %v",
		resp.HTTPStatusCode)
}

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"fmt"

	"github.com/gravitational/trace"
	sheets "google.golang.org/api/sheets/v4"

	"github.com/gravitational/teleport/api/types"
)

func (g *googleSheetsClient) updateRow(ar types.AccessRequest, rowNum int64) error {
	row := g.makeRowData(ar)

	req := sheets.BatchUpdateSpreadsheetRequest{
		Requests: []*sheets.Request{
			{
				UpdateCells: &sheets.UpdateCellsRequest{

					Fields: "*",
					Start: &sheets.GridCoordinate{
						RowIndex: rowNum,
					},
					Rows: []*sheets.RowData{
						row,
					},
				},
			},
		},
	}

	resp, err := g.sheetsClient.BatchUpdate(spreadSheetID, &req).Do()
	if err != nil {
		return trace.Wrap(err)
	}

	if resp.HTTPStatusCode == 201 || resp.HTTPStatusCode == 200 {
		return nil
	}
	return trace.Wrap(
		fmt.Errorf(
			"Unexpected response code updating a row: %v\n",
			resp.HTTPStatusCode),
	)
}

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"errors"

	"github.com/gravitational/trace"

	"github.com/gravitational/teleport/api/types"
)

func (g *googleSheetsClient) updateSpreadsheet(ar types.AccessRequest) error {
	s, err := g.sheetsClient.Get(spreadSheetID).IncludeGridData(true).Do()
	if err != nil {
		return trace.Wrap(err)
	}

	if len(s.Sheets) != 1 {
		return trace.Wrap(
			errors.New("the spreadsheet must have a single sheet"),
		)
	}

	for _, d := range s.Sheets[0].Data {
		for i, r := range d.RowData {
			if r.Values[0] != nil &&
				r.Values[0].UserEnteredValue != nil &&
				r.Values[0].UserEnteredValue.StringValue != nil &&
				*r.Values[0].UserEnteredValue.StringValue == ar.GetName() {
				if err := g.updateRow(ar, int64(i)); err != nil {
					return trace.Wrap(err)
				}
			}
		}
	}
	return nil
}

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"context"
	"fmt"

	"github.com/gravitational/trace"

	"github.com/gravitational/teleport/api/types"
)

func (g *googleSheetsClient) HandleEvent(ctx context.Context, event types.Event) error {
	if event.Resource == nil {
		return nil
	}

	if _, ok := event.Resource.(*types.WatchStatusV1); ok {
		fmt.Println("Successfully started listening for Access Requests...")
		return nil
	}

	r, ok := event.Resource.(types.AccessRequest)
	if !ok {
		fmt.Printf("Unknown (%T) event received, skipping.\n", event.Resource)
		return nil
	}

	if r.GetState() == types.RequestState_PENDING {
		if err := g.createRow(r); err != nil {
			return err
		}
		fmt.Println("Successfully created a row")
		return nil
	}

	if err := g.updateSpreadsheet(r); err != nil {
		return err
	}
	fmt.Println("Successfully updated a spreadsheet row")
	return nil
}

func (p *AccessRequestPlugin) Run() error {
	ctx := context.Background()

	watch, err := p.TeleportClient.NewWatcher(ctx, types.Watch{
		Kinds: []types.WatchKind{
			types.WatchKind{Kind: types.KindAccessRequest},
		},
	})

	if err != nil {
		return trace.Wrap(err)
	}
	defer watch.Close()

	fmt.Println("Starting the watcher job")

	for {
		select {
		case e := <-watch.Events():
			if err := p.EventHandler.HandleEvent(ctx, e); err != nil {
				return trace.Wrap(err)
			}
		case <-watch.Done():
			fmt.Println("The watcher job is finished")
			return nil
		}
	}
}

// 저작권 2023 Gravitational, Inc
//
// Apache License, Version 2.0 ("라이선스")에 따라 라이선스가 부여됩니다.
// 라이선스에 따라 사용하지 않는 한, 이 파일을 사용할 수 없습니다.
// 라이선스 사본은 다음에서 확인할 수 있습니다:
//
//      http://www.apache.org/licenses/LICENSE-2.0
//
// 관련 법률에 의해 요구되거나 서면으로 동의하지 않는 한,
// 이 소프트웨어는 "있는 그대로" 제공되며, 명시적이거나 묵시적인 어떠한 보증도 포함하지 않습니다.
// 라이선스에서 허용하는 권한과 제한 사항에 대한 자세한 내용은 위의 링크를 참조하십시오.


package main

import (
	"context"

	"google.golang.org/api/option"
	sheets "google.golang.org/api/sheets/v4"
	"google.golang.org/grpc"

	"github.com/gravitational/teleport/api/client"
)

func main() {
	ctx := context.Background()
	svc, err := sheets.NewService(ctx, option.WithCredentialsFile("credentials.json"))
	if err != nil {
		panic(err)
	}

	creds := client.LoadIdentityFile("auth.pem")

	teleport, err := client.New(ctx, client.Config{
		Addrs:       []string{proxyAddr},
		Credentials: []client.Credentials{creds},
		DialOpts: []grpc.DialOption{
			grpc.WithReturnConnectionError(),
		},
	})
	if err != nil {
		panic(err)
	}
	defer teleport.Close()

	gs := googleSheetsClient{
		sheetsClient: sheets.NewSpreadsheetsService(svc),
	}

	plugin := AccessRequestPlugin{
		TeleportClient: teleport,
		EventHandler:   &gs,
	}

	if err := plugin.Run(); err != nil {
		panic(err)
	}
}