Add GetPerson API call, add 'label' structure field, add CreateOrg API call, add some custom fields

Author: kben

pipedrive/activities.go

@@ -137,17 +137,17 @@ func (s *ActivitiesService) Create(ctx context.Context, opt *ActivitiesCreateOpt
 // ActivitiesCreateOptions specifices the optional parameters to the
 // ActivitiesService.Update method.
 type ActivitiesCreateOptions struct {
-Subject string `url:"subject,omitempty"`
-Done uint8 `url:"done,omitempty"`
-Type string `url:"type,omitempty"`
-DueDate string `url:"due_date,omitempty"`
-DueTime string `url:"due_time,omitempty"`
-Duration string `url:"duration,omitempty"`
-UserID uint `url:"user_id,omitempty"`
-DealID uint `url:"user_id,omitempty"`
-PersonID uint `url:"person_id,omitempty"`
-Participants interface{} `url:"participants,omitempty"`
-OrgID uint `url:"org_id,omitempty"`
+Subject string `json:"subject,omitempty"`
+Done uint8 `json:"done,omitempty"`
+Type string `json:"type,omitempty"`
+DueDate string `json:"due_date,omitempty"`
+DueTime string `json:"due_time,omitempty"`
+Duration string `json:"duration,omitempty"`
+UserID uint `json:"user_id,omitempty"`
+DealID uint `json:"user_id,omitempty"`
+PersonID uint `json:"person_id,omitempty"`
+Participants interface{} `json:"participants,omitempty"`
+OrgID uint `json:"org_id,omitempty"`
 }
 
 // Update an activity

pipedrive/deals.go

@@ -236,16 +236,17 @@ func (s *DealService) Merge(ctx context.Context, id int, opt *DealsMergeOptions)
 // DealsUpdateOptions specifices the optional parameters to the
 // DealService.Update method.
 type DealsUpdateOptions struct {
-Title string `url:"title,omitempty"`
-Value string `url:"value,omitempty"`
-Currency string `url:"currency,omitempty"`
-UserID uint `url:"user_id,omitempty"`
-PersonID uint `url:"person_id,omitempty"`
-OrganizationID uint `url:"org_id,omitempty"`
-StageID uint `url:"stage_id,omitempty"`
-Status string `url:"status,omitempty"`
-LostReason string `url:"lost_reason,omitempty"`
-VisibleTo uint `url:"visible_to,omitempty"`
+Title string `json:"title,omitempty"`
+Value string `json:"value,omitempty"`
+Currency string `json:"currency,omitempty"`
+UserID uint `json:"user_id,omitempty"`
+PersonID uint `json:"person_id,omitempty"`
+OrganizationID uint `json:"org_id,omitempty"`
+StageID uint `json:"stage_id,omitempty"`
+Status string `json:"status,omitempty"`
+LostReason string `json:"lost_reason,omitempty"`
+VisibleTo uint `json:"visible_to,omitempty"`
+RequirementAnalysis string `json:"56d3d40c37c0db60fff576ae73ba2fea0d58dc09"`
 }
 
 // Update a deal.
@@ -331,3 +332,73 @@ func (s *DealService) DeleteAttachedProduct(ctx context.Context, dealID int, pro
 
 return s.client.Do(ctx, req, nil)
 }
+
+// DealCreateOptions specifices the optional parameters to the
+// DealsService.Create method.
+type DealCreateOptions struct {
+Title string `json:"title"`
+Value string `json:"value"`
+Currency string `json:"currency"`
+UserID uint `json:"user_id"`
+PersonID uint `json:"person_id"`
+OrgID uint `json:"org_id"`
+StageID uint `json:"stage_id"`
+Status string `json:"status"`
+Probability uint `json:"probability"`
+LostReason string `json:"lost_reason"`
+AddTime Timestamp `json:"add_time"`
+VisibleTo VisibleTo `json:"visible_to"`
+RequirementAnalysis string `json:"56d3d40c37c0db60fff576ae73ba2fea0d58dc09"`
+WantedStartTime Timestamp `json:"a3114acce61bb930180af173b395d76f42af8794"`
+}
+
+// Create a new deal.
+//
+// Pipedrive API docs: https://developers.pipedrive.com/docs/api/v1/#!/Deals/post_deals
+func (s *DealService) Create(ctx context.Context, opt *DealCreateOptions) (*DealResponse, *Response, error) {
+req, err := s.client.NewRequest(http.MethodPost, "/deals", nil, struct {
+Title string `json:"title"`
+Value string `json:"value"`
+Currency string `json:"currency"`
+UserID uint `json:"user_id"`
+PersonID uint `json:"person_id"`
+OrgID uint `json:"org_id"`
+StageID uint `json:"stage_id"`
+Status string `json:"status"`
+Probability uint `json:"probability"`
+LostReason string `json:"lost_reason"`
+AddTime string `json:"add_time"`
+VisibleTo VisibleTo `json:"visible_to"`
+RequirementAnalysis string `json:"56d3d40c37c0db60fff576ae73ba2fea0d58dc09"`
+WantedStartTime string `json:"a3114acce61bb930180af173b395d76f42af8794"`
+}{
+opt.Title,
+opt.Value,
+opt.Currency,
+opt.UserID,
+opt.PersonID,
+opt.OrgID,
+opt.StageID,
+opt.Status,
+opt.Probability,
+opt.LostReason,
+opt.AddTime.FormatFull(),
+opt.VisibleTo,
+opt.RequirementAnalysis,
+opt.WantedStartTime.FormatFull(),
+})
+
+if err != nil {
+return nil, nil, err
+}
+
+var record *DealResponse
+
+resp, err := s.client.Do(ctx, req, &record)
+
+if err != nil {
+return nil, resp, err
+}
+
+return record, resp, nil
+}

pipedrive/notes.go

@@ -92,13 +92,13 @@ func (s *NotesService) GetByID(ctx context.Context, id int) (*NoteResponse, *Res
 // NoteCreateOptions specifices the optional parameters to the
 // NotesService.Create method.
 type NoteCreateOptions struct {
-DealID uint `url:"deal_id"`
-Content string `url:"content"`
-PersonID uint `url:"person_id"`
-OrgID uint `url:"org_id"`
-PinnedToDealFlag uint8 `url:"pinned_to_deal_flag"`
-PinnedToOrganizationFlag uint8 `url:"pinned_to_organization_flag"`
-PinnedToPersonFlag uint8 `url:"pinned_to_person_flag"`
+DealID uint `json:"deal_id"`
+Content string `json:"content"`
+PersonID uint `json:"person_id"`
+OrgID uint `json:"org_id"`
+PinnedToDealFlag uint8 `json:"pinned_to_deal_flag"`
+PinnedToOrganizationFlag uint8 `json:"pinned_to_organization_flag"`
+PinnedToPersonFlag uint8 `json:"pinned_to_person_flag"`
 }
 
 // Create a note.

pipedrive/organizations.go

@@ -180,3 +180,46 @@ func (s *OrganizationsService) DeleteMultiple(ctx context.Context, ids []int) (*
 
 return s.client.Do(ctx, req, nil)
 }
+
+// OrganizationCreateOptions specifices the optional parameters to the
+// OrganizationsService.Create method.
+type OrganizationCreateOptions struct {
+Name string `json:"name"`
+OwnerID uint `json:"owner_id"`
+VisibleTo VisibleTo `json:"visible_to"`
+AddTime Timestamp `json:"add_time"`
+Label uint `json:"label"`
+}
+
+// Create a new organizations.
+//
+// Pipedrive API docs: https://developers.pipedrive.com/docs/api/v1/#!/Organizations/post_organizations
+func (s *OrganizationsService) Create(ctx context.Context, opt *OrganizationCreateOptions) (*OrganizationResponse, *Response, error) {
+req, err := s.client.NewRequest(http.MethodPost, "/organizations", nil, struct {
+Name string `json:"name"`
+OwnerID uint `json:"owner_id"`
+Label uint `json:"label"`
+VisibleTo VisibleTo `json:"visible_to"`
+AddTime string `json:"add_time"`
+}{
+opt.Name,
+opt.OwnerID,
+opt.Label,
+opt.VisibleTo,
+opt.AddTime.FormatFull(),
+})
+
+if err != nil {
+return nil, nil, err
+}
+
+var record *OrganizationResponse
+
+resp, err := s.client.Do(ctx, req, &record)
+
+if err != nil {
+return nil, resp, err
+}
+
+return record, resp, nil
+}

pipedrive/persons.go

@@ -73,6 +73,7 @@ type Person struct {
 OrgName interface{} `json:"org_name"`
 OwnerName string `json:"owner_name"`
 CcEmail string `json:"cc_email"`
+Label uint `json:"label"`
 }
 
 func (p Person) String() string {
@@ -161,6 +162,7 @@ type PersonCreateOptions struct {
 Phone string `json:"phone"`
 VisibleTo VisibleTo `json:"visible_to"`
 AddTime Timestamp `json:"add_time"`
+Label uint `json:"label"`
 }
 
 // Create a new person.
@@ -173,6 +175,7 @@ func (s *PersonsService) Create(ctx context.Context, opt *PersonCreateOptions) (
 OrgID uint `json:"org_id"`
 Email string `json:"email"`
 Phone string `json:"phone"`
+Label uint `json:"label"`
 VisibleTo VisibleTo `json:"visible_to"`
 AddTime string `json:"add_time"`
 }{
@@ -181,6 +184,7 @@ func (s *PersonsService) Create(ctx context.Context, opt *PersonCreateOptions) (
 opt.OrgID,
 opt.Email,
 opt.Phone,
+opt.Label,
 opt.VisibleTo,
 opt.AddTime.FormatFull(),
 })
@@ -315,3 +319,24 @@ func (s *PersonsService) DeleteMultiple(ctx context.Context, ids []int) (*Respon
 
 return s.client.Do(ctx, req, nil)
 }
+
+// Get a person.
+//
+// Pipedrive API docs: https://developers.pipedrive.com/docs/api/v1/#!/Persons/get_persons_id
+func (s *PersonsService) Get(ctx context.Context, personID int) (*PersonResponse, *Response, error) {
+req, err := s.client.NewRequest(http.MethodGet, fmt.Sprintf("/persons/%d", personID), nil, nil)
+
+if err != nil {
+return nil, nil, err
+}
+
+var record *PersonResponse
+
+resp, err := s.client.Do(ctx, req, &record)
+
+if err != nil {
+return nil, resp, err
+}
+
+return record, resp, nil
+}