addDeliveries

import sys
import logging
from suds.client import Client
from suds import WebFault
from datetime import datetime

"""
This example script will login in to the API, obtain
a message ID and contact ID, and use those IDs to
send the message to the contact. This script assumes
the email message being sent contains {loop}{/loop}
tags and the following the API message tags contained 
within the loop tags: 
%%#productname_#%%
%%#productprice_#%%

BE SURE TO REPLACE ALL PLACEHOLDER TEXT

Tested with Python 2.6.1 and suds soap library version 0.4

See suds home page:
https://fedorahosted.org/suds/

"""

# Bronto API WSDL
BRONTO_WSDL = 'https://api.bronto.com/v4?wsdl'

# Start up basic logging
logging.basicConfig()

# Replace the placeholder text with a valid
# API token
TOKEN = "ADD API TOKEN HERE"


# Login using the token to obtain a session ID
bApi = Client( BRONTO_WSDL )

try:
	session_id = bApi.service.login(TOKEN)
# Just exit if something goes wrong
except WebFault, e:
   print '\nERROR MESSAGE:'
   print e
   sys.exit()

# Set up the soap headers using the
# session_id obtained from login()
session_header = bApi.factory.create("sessionHeader")
session_header.sessionId = session_id
bApi.set_options(soapheaders=session_header)

# Get the ID of the message you wish to 
# send by calling readMessages.
# Make sure the message contains {loop}{/loop}
# tags and the following the API message tags contained 
# within the loop tags: 
# 		%%#productname_#%%
# 		%%#productprice_#%%
# Be sure to replace the placeholder text below	

messageFilter = bApi.factory.create('messageFilter')

message_name = bApi.factory.create('stringValue')
filter_operator = bApi.factory.create('filterOperator')
message_name.operator = filter_operator.EqualTo
message_name.value = 'SOME MESSAGE NAME'
messageFilter.name = message_name

filterType = bApi.factory.create('filterType')
messageFilter.type = filterType.AND

try:
	read_message = bApi.service.readMessages(messageFilter, includeContent = False, pageNumber = 1)
	print 'The id for the message: ' + read_message[0].id
except WebFault, e:
	print '\nERROR MESSAGE:'
	print e
	sys.exit()

# Get the ID of the contact you wish to send
# to by calling readContacts,
# Be sure to replace the placeholder text below	
filter = bApi.factory.create('contactFilter')

stringValue = bApi.factory.create('stringValue')
stringValue.value = 'SOME EMAIL ADDRESS'
filterOperator = bApi.factory.create('filterOperator')
stringValue.operator = filterOperator.EqualTo

filterType = bApi.factory.create('filterType')

filter.email = stringValue
filter.type = filterType.AND

try:
	read_contact = bApi.service.readContacts(filter, includeLists = True, pageNumber = 1)
	print 'Contact ID: ' + read_contact[0].id
except WebFault, e:
	print '\nERROR MESSAGE:'
	print e
	sys.exit()

# Get the current date and time so we can send the 
# email message now	
sendtime = datetime.now()

# Call addDeliveries using the send time, message ID, and 
# contact ID specified above.
# Be sure to replace the placeholder text below	

add_delivery = bApi.factory.create('deliveryObject')
add_delivery.start = sendtime
add_delivery.messageId = read_message[0].id
add_delivery.fromName = 'SOME FROM NAME'
add_delivery.fromEmail = 'SOME FROM EXAMPLE'

deliveryRecipientObject = bApi.factory.create('deliveryRecipientObject')
deliveryRecipientObject.type = 'contact'
deliveryRecipientObject.id = read_contact[0].id
add_delivery.recipients = deliveryRecipientObject

fieldObject = bApi.factory.create('messageFieldObject')

add_delivery.fields = fieldObject

# Create a fieldObject list of each
# fieldName and fieldPrice
fieldObject = []

# For each fieldName and fieldPrice, create
# a dictionary containing a name, type, and content, and
# then append that dicitionary to the fieldObject list.

fieldName0 = {}
fieldName0['name'] = 'productname_0'
fieldName0['type'] =  'html'
fieldName0['content'] =  'A Cool Shirt'
fieldObject.append(fieldName0)

fieldName1 = {}
fieldName1['name'] = 'productname_1'
fieldName1['type'] = 'html'
fieldName1['content'] = 'Some Nice Shoes'
fieldObject.append(fieldName1)

fieldName2 = {}
fieldName2['name'] = 'productname_2'
fieldName2['type'] = 'html'
fieldName2['content'] = 'A Trendy Hat'
fieldObject.append(fieldName2)

fieldPrice0 = {}
fieldPrice0['name'] = 'productprice_0'
fieldPrice0['type'] = 'html'
fieldPrice0['content'] = '20.99'
fieldObject.append(fieldPrice0)

fieldPrice1 = {}
fieldPrice1['name'] = 'productprice_1'
fieldPrice1['type'] = 'html'
fieldPrice1['content'] = '50.99'
fieldObject.append(fieldPrice1)

fieldPrice2 = {}
fieldPrice2['name'] = 'productprice_2'
fieldPrice2['type'] = 'html'
fieldPrice2['content'] = 'FREE'
fieldObject.append(fieldPrice2)



add_delivery.fields = fieldObject


try:
	delivery = bApi.service.addDeliveries(add_delivery)
	if delivery.results[0].isError == True:
		print 'There was an error with your request:'
		print delivery.results[0]
		sys.exit()
	else:
		print 'The delivery has been sent. The delivery ID is: ' + delivery.results[0].id
except WebFault, e:
	print '\nERROR MESSAGE:'
	print e
	sys.exit()