[fix #1701] Use DS form to enroll admin

app/lib/pipedrive/api.rb

@@ -2,6 +2,7 @@ class Pipedrive::API
   PIPEDRIVE_ALL_NOT_DELETED_DEALS = 'all_not_deleted'
   PIPEDRIVE_DEALS_URL = [PIPEDRIVE_API_URL, 'deals'].join("/")
   PIPEDRIVE_PEOPLE_URL = [PIPEDRIVE_API_URL, 'persons'].join("/")
+  PIPEDRIVE_ORGANIZATIONS_URL = [PIPEDRIVE_API_URL, 'organizations'].join("/")
 
   def self.get_persons_owned_by_user(user_id)
     url = PIPEDRIVE_PEOPLE_URL
@@ -23,12 +24,24 @@ class Pipedrive::API
     self.put(url, params)
   end
 
+  def self.post_deal(params)
+    self.post(PIPEDRIVE_DEALS_URL, params)
+  end
+
   def self.put_person(person_id, params)
     url = [PIPEDRIVE_PEOPLE_URL, person_id].join("/")
 
     self.put(url, params)
   end
 
+  def self.post_person(params)
+    self.post(PIPEDRIVE_PEOPLE_URL, params)
+  end
+
+  def self.post_organization(params)
+    self.post(PIPEDRIVE_ORGANIZATIONS_URL, params)
+  end
+
   private
 
   def self.get(url, params)
@@ -47,4 +60,10 @@ class Pipedrive::API
 
     RestClient.put(url, params.to_json, { content_type: :json })
   end
+
+  def self.post(url, params)
+    url = "#{url}?api_token=#{PIPEDRIVE_TOKEN}"
+
+    RestClient.post(url, params.to_json, { content_type: :json })
+  end
 end

app/lib/pipedrive/deal_adapter.rb

@@ -33,4 +33,15 @@ class Pipedrive::DealAdapter
 
     Pipedrive::API.put_deal(deal_id, params)
   end
+
+  def self.add_deal(organisation_id, person_id, title)
+    params = {
+      org_id: organisation_id,
+      person_id: person_id,
+      title: title,
+      user_id: Pipedrive::PersonAdapter::PIPEDRIVE_ROBOT_ID
+    }
+
+    Pipedrive::API.post_deal(params)
+  end
 end

app/lib/pipedrive/organization_adapter.rb

@@ -0,0 +1,13 @@
+class Pipedrive::OrganizationAdapter
+  def self.add_organization(name, address)
+    params = {
+      name: name,
+      owner_id: Pipedrive::PersonAdapter::PIPEDRIVE_ROBOT_ID,
+      address: address
+    }
+
+    response = Pipedrive::API.post_organization(params)
+
+    JSON.parse(response.body)['data']['id']
+  end
+end

app/lib/pipedrive/person_adapter.rb

@@ -1,5 +1,6 @@
 class Pipedrive::PersonAdapter
   PIPEDRIVE_POSTE_ATTRIBUTE_ID = '33a790746f1713d712fe97bcce9ac1ca6374a4d6'
+  PIPEDRIVE_SOURCE_ATTRIBUTE_ID = '2fa7864f467ffa97721cbcd08df5a3d591b15f50'
   PIPEDRIVE_ROBOT_ID = '2748449'
 
   def self.get_demandes_from_persons_owned_by_robot
@@ -19,4 +20,20 @@ class Pipedrive::PersonAdapter
 
     Pipedrive::API.put_person(person_id, params)
   end
+
+  def self.add_person(email, phone, name, organization_id, poste, source)
+    params = {
+      email: email,
+      phone: phone,
+      name: name,
+      org_id: organization_id,
+      owner_id: PIPEDRIVE_ROBOT_ID,
+      "#{PIPEDRIVE_POSTE_ATTRIBUTE_ID}": poste,
+      "#{PIPEDRIVE_SOURCE_ATTRIBUTE_ID}": source
+    }
+
+    response = Pipedrive::API.post_person(params)
+
+    JSON.parse(response.body)['data']['id']
+  end
 end