telegram-stepfunctions-bot/serverless.yml at master · Andrii-D/telegram-stepfunctions-bot · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
service: telegram-stepfunction-bot

frameworkVersion: ">=1.2.0 <2.0.0"

provider:
  name: aws
  runtime: python2.7
  stage: dev
  region: us-east-1
  memorySize: 128
  environment:
    TELEGRAM_TOKEN: ${env:TELEGRAM_TOKEN}
    MESSAGES_TABLE: ${self:service}-${opt:stage, self:provider.stage}-stepfunction-bot-messages
    USERS_TABLE: ${self:service}-${opt:stage, self:provider.stage}-stepfunction-bot-users
  iamRoleStatements:
    - Effect: Allow
      Action:
        - dynamodb:Query
        - dynamodb:Scan
        - dynamodb:GetItem
        - dynamodb:PutItem
        - dynamodb:UpdateItem
        - dynamodb:DeleteItem
      Resource: "arn:aws:dynamodb:${opt:region, self:provider.region}:*:table/*"

functions:
  receive:
    description: Receive message
    handler: handler.receive

  respond:
    description: Respond to user
    handler: handler.respond

  log:
      description: Save all messages to DynamoDB
      handler: handler.log

  authorize:
        description: Authorize user
        handler: handler.authorize

stepFunctions:
  stateMachines:
    BotStateMachine:
      events:
        - http:
            path: telegram-${self:provider.stage}-bot
            method: post
            cors: true
      definition:
        Comment: "Telegram bot State Machine"
        StartAt: parallel
        States:
          parallel:
            Type: Parallel
            Next: final_state
            ResultPath: $.results.parallel
            Branches:
              - StartAt: log
                States:
                  log:
                    Type: Task
                    Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:${self:service}-${opt:stage}-log"
                    End: true
              - StartAt: receive
                States:
                  receive:
                    Type: Task
                    Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:${self:service}-${opt:stage}-receive"
                    Next: AuthOrNot
                    ResultPath: $.results.receive
                  AuthOrNot:
                    Type: Choice
                    Choices:
                    - Variable: "$.results.receive.authorize"
                      NumericEquals: 1
                      Next: authorize
                    Default: respond
                  respond:
                    Type: Task
                    Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:${self:service}-${opt:stage}-respond"
                    End: true
                    ResultPath: $.results.respond
                  authorize:
                    Type: Task
                    Resource: "arn:aws:lambda:#{AWS::Region}:#{AWS::AccountId}:function:${self:service}-${opt:stage}-authorize"
                    Next: respond
                    ResultPath: $.results.authorize
          final_state:
            Type: Pass
            End: true


resources:
  Resources:
    MessagesDynamoDbTable:
      Type: 'AWS::DynamoDB::Table'
      DeletionPolicy: Retain
      Properties:
        AttributeDefinitions:
          -
            AttributeName: key
            AttributeType: S
        KeySchema:
          -
            AttributeName: key
            KeyType: HASH
        ProvisionedThroughput:
          ReadCapacityUnits: 1
          WriteCapacityUnits: 1
        TableName: ${self:provider.environment.MESSAGES_TABLE}
    UsersDynamoDbTable:
      Type: 'AWS::DynamoDB::Table'
      DeletionPolicy: Retain
      Properties:
        AttributeDefinitions:
          -
            AttributeName: username
            AttributeType: S
        KeySchema:
          -
            AttributeName: username
            KeyType: HASH
        ProvisionedThroughput:
          ReadCapacityUnits: 1
          WriteCapacityUnits: 1
        TableName: ${self:provider.environment.USERS_TABLE}

package:
  exclude:
    - ./node_modules/*

plugins:
  - serverless-step-functions
  - serverless-pseudo-parameters