apiVersion: siddhi.io/v1alpha1
kind: SiddhiProcess
metadata:
  name: monitor-app
  version: 1.0.0
spec:
  pod:
   image: siddhiio/siddhi-runner-alpine
   imageTag: 0.1.0
  tls:
    ingressSecret: siddhi-tls
  env: 
    - name: RECEIVER_URL
      value: "http://0.0.0.0:8280/example"
    - name: BASIC_AUTH_ENABLED
      value: "false"
  # apps:
  #   - app1
  #   - app2
  query: |
    @App:name("MonitorApp")
    @App:description("Description of the plan") 
    
    @sink(type='log', prefix='LOGGER')
    @source(type='http', receiver.url='${RECEIVER_URL}', basic.auth.enabled='${BASIC_AUTH_ENABLED}', @map(type='json'))
    define stream DevicePowerStream (type string, deviceID string, power int);

    
    define stream MonitorDevicesPowerStream(deviceID string, power int);

    @info(name='monitored-filter')
    from DevicePowerStream[type == 'monitored']
    select deviceID, power
    insert into MonitorDevicesPowerStream;
  siddhi.runner.configs: |
    state.persistence:
      enabled: true
      intervalInMin: 5
      revisionsToKeep: 2
      persistenceStore: io.siddhi.distribution.core.persistence.FileSystemPersistenceStore
      config:
        location: siddhi-app-persistence