Class: SOULs::Pubsub

Inherits:
Thor
  • Object
show all
Defined in:
lib/souls/cli/gcloud/pubsub/topics.rb,
lib/souls/cli/gcloud/pubsub/subscriptions.rb

Instance Method Summary collapse

Instance Method Details

#create_subscription ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/souls/cli/gcloud/pubsub/subscriptions.rb', line 12

def create_subscription
  project_id = SOULs.configuration.project_id
   = "#{SOULs.configuration.app}@#{project_id}.iam.gserviceaccount.com"
  system(
    "gcloud pubsub subscriptions create #{options[:topic_name]}-sub \
        --topic #{options[:topic_name]} \
        --topic-project #{project_id} \
        --push-auth-service-account #{} \
        --push-endpoint #{options[:endpoint]} \
        --expiration-period never"
  )
end

#create_topic(topic_name) ⇒ Object 



4
5
6
7
 
# File 'lib/souls/cli/gcloud/pubsub/topics.rb', line 4

def create_topic(topic_name)
  project = SOULs.configuration.project_id
  system("gcloud pubsub topics create #{topic_name} --project=#{project}")
end

#subscription_list ⇒ Object 



26
27
28
 
# File 'lib/souls/cli/gcloud/pubsub/subscriptions.rb', line 26

def subscription_list
  system("gcloud pubsub subscriptions list")
end

#topic_list ⇒ Object 



10
11
12
13
 
# File 'lib/souls/cli/gcloud/pubsub/topics.rb', line 10

def topic_list
  project = SOULs.configuration.project_id
  system("gcloud pubsub topics list --project=#{project}")
end

#update_subscription ⇒ Object 



39
40
41
 
# File 'lib/souls/cli/gcloud/pubsub/subscriptions.rb', line 39

def update_subscription
  system("gcloud pubsub subscriptions update #{options[:topic_name]}-sub --push-endpoint #{options[:endpoint]} ")
end