Push a contact to Pipedrive using structured person / org / deal objects.

curl --request POST \
  --url https://mcp.sagescreen.net/tools/contact_push \
  --header 'Content-Type: application/json' \
  --header 'X-Service-Token: <api-key>' \
  --data '
{
  "user_id": 123,
  "person": {},
  "org": {},
  "deal": {},
  "dm": "<string>",
  "notes": "<string>",
  "sequence_id": 123,
  "skip_note": false,
  "skip_blob_note": false,
  "skip_dm_activity": false,
  "skip_followup": false,
  "skip_enrich": false
}
'

import requests

url = "https://mcp.sagescreen.net/tools/contact_push"

payload = {
    "user_id": 123,
    "person": {},
    "org": {},
    "deal": {},
    "dm": "<string>",
    "notes": "<string>",
    "sequence_id": 123,
    "skip_note": False,
    "skip_blob_note": False,
    "skip_dm_activity": False,
    "skip_followup": False,
    "skip_enrich": False
}
headers = {
    "X-Service-Token": "<api-key>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {'X-Service-Token': '<api-key>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    user_id: 123,
    person: {},
    org: {},
    deal: {},
    dm: '<string>',
    notes: '<string>',
    sequence_id: 123,
    skip_note: false,
    skip_blob_note: false,
    skip_dm_activity: false,
    skip_followup: false,
    skip_enrich: false
  })
};

fetch('https://mcp.sagescreen.net/tools/contact_push', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://mcp.sagescreen.net/tools/contact_push",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'user_id' => 123,
    'person' => [
        
    ],
    'org' => [
        
    ],
    'deal' => [
        
    ],
    'dm' => '<string>',
    'notes' => '<string>',
    'sequence_id' => 123,
    'skip_note' => false,
    'skip_blob_note' => false,
    'skip_dm_activity' => false,
    'skip_followup' => false,
    'skip_enrich' => false
  ]),
  CURLOPT_HTTPHEADER => [
    "Content-Type: application/json",
    "X-Service-Token: <api-key>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://mcp.sagescreen.net/tools/contact_push"

	payload := strings.NewReader("{\n  \"user_id\": 123,\n  \"person\": {},\n  \"org\": {},\n  \"deal\": {},\n  \"dm\": \"<string>\",\n  \"notes\": \"<string>\",\n  \"sequence_id\": 123,\n  \"skip_note\": false,\n  \"skip_blob_note\": false,\n  \"skip_dm_activity\": false,\n  \"skip_followup\": false,\n  \"skip_enrich\": false\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("X-Service-Token", "<api-key>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://mcp.sagescreen.net/tools/contact_push")
  .header("X-Service-Token", "<api-key>")
  .header("Content-Type", "application/json")
  .body("{\n  \"user_id\": 123,\n  \"person\": {},\n  \"org\": {},\n  \"deal\": {},\n  \"dm\": \"<string>\",\n  \"notes\": \"<string>\",\n  \"sequence_id\": 123,\n  \"skip_note\": false,\n  \"skip_blob_note\": false,\n  \"skip_dm_activity\": false,\n  \"skip_followup\": false,\n  \"skip_enrich\": false\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://mcp.sagescreen.net/tools/contact_push")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["X-Service-Token"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"user_id\": 123,\n  \"person\": {},\n  \"org\": {},\n  \"deal\": {},\n  \"dm\": \"<string>\",\n  \"notes\": \"<string>\",\n  \"sequence_id\": 123,\n  \"skip_note\": false,\n  \"skip_blob_note\": false,\n  \"skip_dm_activity\": false,\n  \"skip_followup\": false,\n  \"skip_enrich\": false\n}"

response = http.request(request)
puts response.read_body

{}

{
  "error": "<string>",
  "detail": "<string>"
}

{
  "error": "Unauthorized"
}

{
  "error": "<string>",
  "detail": "<string>"
}

{
  "error": "<string>",
  "detail": "<string>"
}

Contact Push

Push a contact to Pipedrive using structured person / org / deal objects.

Push a contact to Pipedrive using structured person / org / deal objects. Returns {job_id, status:'accepted'} immediately; poll contact_push_status. Required identification: user_id: Pipedrive user id who will OWN the created person/org/deal. person: Required dict. Must contain `li_url` and/or `email`. The person object also holds all person-level fields (built-in or custom), addressed by Pipedrive field KEY (see "Field keys" below), plus its own `overwrite` flag. person = { "li_url": "https://linkedin.com/in/...", # well-known: dedupe key "email": "theo@x.com", # well-known: dedupe key "name": "Theo Meinzer", # well-known: caller name always wins "phone": "+1...", # any PD field key "<hash>": "...", # any custom field key "overwrite": false } Org (optional): org: Dict. Identification keys drive create-or-match (Pipedrive is SOT for dedupe). Other keys are PD field-key writes. Omit `org` to skip org entirely (person will not be linked). org = { "li_url": "https://linkedin.com/company/...", # well-known: tried first "name": "SBH Fashion", # well-known: name match / create "<any field key>": "value", "overwrite": false } Org lookup order: LI URL → name exact. On miss + `name` provided, a new org is created (and linked to `li_url` if given so future lookups dedupe). Deal (optional): deal: Dict. Omit `deal` entirely to skip deal creation/reuse. If provided (even as `{}`), an OPEN deal on this person in the chosen pipeline is reused; otherwise a new one is created. deal = { "stage": "new", # well-known: stage NAME for new deals "pipeline_id": 5, # well-known: defaults to CONTACT_PUSH_DEFAULT_PIPELINE_ID "title": "...", # well-known: defaults to "<Name> - <Company>" "value": 50000, # any PD field key "currency": "USD", "<hash>": "...", "overwrite": false } Top-level behavior flags (all default off / unset): sequence_id: Reply.io campaign id; enroll the email there (silent no-op if no email). dm: LinkedIn DM text. If non-empty AND skip_dm_activity is false, creates a "linkedin_message" activity marked done=today. notes: Free-text appended under "--- Notes ---" in the Pipedrive note. skip_note: Skip the ENTIRE note. Overrides skip_blob_note; `notes` dropped. skip_blob_note: Suppress only the auto LinkedIn-header + blob portion; `notes` still creates a note if non-empty. skip_dm_activity: Skip the DM activity even when `dm` is supplied. skip_followup: Skip the 5-day followup task on newly-created deals. skip_enrich: Skip Apollo entirely — no enrichment, no LI-URL pre-fetch from email. Useful when records are already enriched upstream. Caller-supplied `person.name`, `org.name`, `org.li_url` are the only sources in this mode. Dedupe behavior: Person lookup order: (1) LinkedIn URL custom field → (2) email exact match → (3) name exact match. First hit wins; existing person is reused and any missing fields backfilled from Apollo (unless `skip_enrich=true`). Org lookup: by LI URL (if `org.li_url`) → name exact. Reused, never duplicated. Deal lookup: an OPEN deal on this person in this pipeline is reused. Field keys: Inside `person`, `org`, `deal`, any key NOT in the well-known set is treated as a Pipedrive field KEY — either a 40-char hashed custom-field key (e.g. "855c1c9c8864dad6fa56c82fd957b9c1a214508b") or a short stable key for built-ins (e.g. "phone", "value", "currency"). Field NAMES are not supported. Use `pd_fields_list` to discover keys. Unknown keys raise a ValueError listing the offending {entity, field}. Overwrite: Each object carries its own `overwrite` flag. When false (default), only empty fields on the existing record are filled (backfill). When true, every provided field is written, replacing whatever was there.

POST

tools

contact_push

curl --request POST \
  --url https://mcp.sagescreen.net/tools/contact_push \
  --header 'Content-Type: application/json' \
  --header 'X-Service-Token: <api-key>' \
  --data '
{
  "user_id": 123,
  "person": {},
  "org": {},
  "deal": {},
  "dm": "<string>",
  "notes": "<string>",
  "sequence_id": 123,
  "skip_note": false,
  "skip_blob_note": false,
  "skip_dm_activity": false,
  "skip_followup": false,
  "skip_enrich": false
}
'

import requests

url = "https://mcp.sagescreen.net/tools/contact_push"

payload = {
    "user_id": 123,
    "person": {},
    "org": {},
    "deal": {},
    "dm": "<string>",
    "notes": "<string>",
    "sequence_id": 123,
    "skip_note": False,
    "skip_blob_note": False,
    "skip_dm_activity": False,
    "skip_followup": False,
    "skip_enrich": False
}
headers = {
    "X-Service-Token": "<api-key>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {'X-Service-Token': '<api-key>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    user_id: 123,
    person: {},
    org: {},
    deal: {},
    dm: '<string>',
    notes: '<string>',
    sequence_id: 123,
    skip_note: false,
    skip_blob_note: false,
    skip_dm_activity: false,
    skip_followup: false,
    skip_enrich: false
  })
};

fetch('https://mcp.sagescreen.net/tools/contact_push', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://mcp.sagescreen.net/tools/contact_push",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'user_id' => 123,
    'person' => [
        
    ],
    'org' => [
        
    ],
    'deal' => [
        
    ],
    'dm' => '<string>',
    'notes' => '<string>',
    'sequence_id' => 123,
    'skip_note' => false,
    'skip_blob_note' => false,
    'skip_dm_activity' => false,
    'skip_followup' => false,
    'skip_enrich' => false
  ]),
  CURLOPT_HTTPHEADER => [
    "Content-Type: application/json",
    "X-Service-Token: <api-key>"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://mcp.sagescreen.net/tools/contact_push"

	payload := strings.NewReader("{\n  \"user_id\": 123,\n  \"person\": {},\n  \"org\": {},\n  \"deal\": {},\n  \"dm\": \"<string>\",\n  \"notes\": \"<string>\",\n  \"sequence_id\": 123,\n  \"skip_note\": false,\n  \"skip_blob_note\": false,\n  \"skip_dm_activity\": false,\n  \"skip_followup\": false,\n  \"skip_enrich\": false\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("X-Service-Token", "<api-key>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://mcp.sagescreen.net/tools/contact_push")
  .header("X-Service-Token", "<api-key>")
  .header("Content-Type", "application/json")
  .body("{\n  \"user_id\": 123,\n  \"person\": {},\n  \"org\": {},\n  \"deal\": {},\n  \"dm\": \"<string>\",\n  \"notes\": \"<string>\",\n  \"sequence_id\": 123,\n  \"skip_note\": false,\n  \"skip_blob_note\": false,\n  \"skip_dm_activity\": false,\n  \"skip_followup\": false,\n  \"skip_enrich\": false\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://mcp.sagescreen.net/tools/contact_push")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["X-Service-Token"] = '<api-key>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"user_id\": 123,\n  \"person\": {},\n  \"org\": {},\n  \"deal\": {},\n  \"dm\": \"<string>\",\n  \"notes\": \"<string>\",\n  \"sequence_id\": 123,\n  \"skip_note\": false,\n  \"skip_blob_note\": false,\n  \"skip_dm_activity\": false,\n  \"skip_followup\": false,\n  \"skip_enrich\": false\n}"

response = http.request(request)
puts response.read_body

{}

{
  "error": "<string>",
  "detail": "<string>"
}

{
  "error": "Unauthorized"
}

{
  "error": "<string>",
  "detail": "<string>"
}

{
  "error": "<string>",
  "detail": "<string>"
}

Authorizations

X-Service-Token

string

header

required

Body

application/json

user_id

integer

required

person

Person · object

required

org

Org · object | null

deal

Deal · object | null

string | null

notes

string | null

sequence_id

integer | null

skip_note

boolean | null

default:false

skip_blob_note

boolean | null

default:false

skip_dm_activity

boolean | null

default:false

skip_followup

boolean | null

default:false

skip_enrich

boolean | null

default:false

Response

Tool result. The shape is tool-specific; most tools return a JSON object, some a {"result": ...} envelope.

The response is of type object.

mcp.sagescreen.net (running)

mcp.sagescreen.app (coming soon)

Push a contact to Pipedrive using structured person / org / deal objects.

Authorizations

Body

Response