Skip to content
This repository has been archived by the owner on May 3, 2019. It is now read-only.

Commit

Permalink
#2 support ad proxy
Browse files Browse the repository at this point in the history
  • Loading branch information
@maratbakirov
maratbakirov committed Mar 27, 2019
1 parent b811cb5 commit f123500
Show file tree
Hide file tree
Showing 2 changed files with 99 additions and 95 deletions.
98 changes: 49 additions & 49 deletions SPMeta2.NintexExt.CSOM.SP13/Handlers/NintexFormHandler.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@
using System.Xml.Linq;
using System.Runtime.Serialization.Json;
using SPMeta2.Common;
using System.Reflection;

namespace SPMeta2.NintexExt.CSOM.SP13.Handlers
{
Expand Down Expand Up @@ -77,58 +78,57 @@ public override void DeployModel(object modelHost, DefinitionBase model)

var publishUrl = UrlUtility.CombineUrl(clientContext.Url, "/_vti_bin/NintexFormsServices/NfRestService.svc/PublishFormXml");

var executor = clientContext.WebRequestExecutorFactory.CreateWebRequestExecutor(clientContext, publishUrl);
executor.RequestContentType = "application/json";
executor.RequestContentType = "application/json; charset=utf-8";

executor.RequestHeaders.Add("X-RequestDigest", formDigestValue);
//executor.RequestHeaders.Add(HttpRequestHeader.AcceptEncoding, "gzip, deflate");
//executor.RequestHeaders.Add(HttpRequestHeader.ContentEncoding, "utf-8");
executor.RequestMethod = "POST";

var serializedObject = NintexFormSerialize.FromDefinition(formModel, clientContext, web, list);

var requestStream = executor.GetRequestStream();
DataContractJsonSerializer ser = new DataContractJsonSerializer(typeof(NintexFormSerialize));
ser.WriteObject(requestStream, serializedObject);
requestStream.Close();
//TODO:
// instead if using requestor.execute, run the following
// ClientRuntimeContext.SetupRequestCredential(m_context, m_webRequest);
//
//var webrequestexecutor = context.WebRequestExecutorFactory.CreateWebRequestExecutor(context, url);
//HttpWebRequest request = webrequestexecutor.WebRequest;
//ClientRuntimeContext.SetupRequestCredential(context, request);
//var FireExecutingWebRequestEventInternalMethod = typeof(ClientContext).GetMethod("FireExecutingWebRequestEventInternal",
// BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
//FireExecutingWebRequestEventInternalMethod.Invoke(context, new object[] { new WebRequestEventArgs(webrequestexecutor) });

//var result = "";
//var response = request.GetResponse();
//using (StreamReader sr = new StreamReader(response.GetResponseStream()))
//{
// result = sr.ReadToEnd();
//}

executor.Execute();
string result = "";

using (StreamReader sr = new StreamReader(executor.GetResponseStream()))
using (var webrequestexecutor = clientContext.WebRequestExecutorFactory.CreateWebRequestExecutor(clientContext, publishUrl))
{
result = sr.ReadToEnd();
webrequestexecutor.RequestContentType = "application/json";
webrequestexecutor.RequestContentType = "application/json; charset=utf-8";

webrequestexecutor.RequestHeaders.Add("X-RequestDigest", formDigestValue);
//executor.RequestHeaders.Add(HttpRequestHeader.AcceptEncoding, "gzip, deflate");
//executor.RequestHeaders.Add(HttpRequestHeader.ContentEncoding, "utf-8");
webrequestexecutor.RequestMethod = "POST";

var serializedObject = NintexFormSerialize.FromDefinition(formModel, clientContext, web, list);


HttpWebRequest request = webrequestexecutor.WebRequest;
ClientRuntimeContext.SetupRequestCredential(clientContext, request);
var FireExecutingWebRequestEventInternalMethod = typeof(ClientContext).GetMethod("FireExecutingWebRequestEventInternal",
BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
FireExecutingWebRequestEventInternalMethod.Invoke(clientContext, new object[] { new WebRequestEventArgs(webrequestexecutor) });

var requestStream = webrequestexecutor.GetRequestStream();
DataContractJsonSerializer ser = new DataContractJsonSerializer(typeof(NintexFormSerialize));
ser.WriteObject(requestStream, serializedObject);
requestStream.Close();

var result = "";
var response = request.GetResponse();
using (StreamReader sr = new StreamReader(response.GetResponseStream()))
{
result = sr.ReadToEnd();
}

//executor.Execute();
//string result = "";

//using (StreamReader sr = new StreamReader(executor.GetResponseStream()))
//{
// result = sr.ReadToEnd();
//}

InvokeOnModelEvent(this, new ModelEventArgs
{
CurrentModelNode = null,
Model = null,
EventType = ModelEventType.OnProvisioned,
Object = result,
ObjectType = typeof(string),
ObjectDefinition = formModel,
ModelHost = modelHost
});
}

InvokeOnModelEvent(this, new ModelEventArgs
{
CurrentModelNode = null,
Model = null,
EventType = ModelEventType.OnProvisioned,
Object = result,
ObjectType = typeof(string),
ObjectDefinition = formModel,
ModelHost = modelHost
});

}
}
}
96 changes: 50 additions & 46 deletions SPMeta2.NintexExt.CSOM.SP13/Handlers/NintexWorkflowHandlerBase.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@
using System.ServiceModel;
using System.Xml;
using System.Xml.Serialization;
using System.Reflection;

namespace SPMeta2.NintexExt.CSOM.SP13.Handlers
{
Expand Down Expand Up @@ -67,54 +68,53 @@ public override void DeployModel(object modelHost, DefinitionBase model)
var formDigestValue = clientContext.GetFormDigestDirect().DigestValue;
var publishUrl = UrlUtility.CombineUrl(web.Url, "/_vti_bin/NintexWorkflow/Workflow.asmx");

var executor = clientContext.WebRequestExecutorFactory.CreateWebRequestExecutor(clientContext, publishUrl);
executor.RequestMethod = "POST";
executor.RequestContentType = "text/xml; charset=utf-8";
executor.RequestHeaders.Add("X-RequestDigest", formDigestValue);
executor.RequestHeaders.Add("SOAPAction", "\"http://nintex.com/PublishFromNWFXml\"");
executor.RequestHeaders.Add(HttpRequestHeader.AcceptEncoding, "gzip, deflate");
executor.WebRequest.AutomaticDecompression = DecompressionMethods.GZip;

//TODO:
// instead if using requestor.execute, run the following
// ClientRuntimeContext.SetupRequestCredential(m_context, m_webRequest);
//
//var webrequestexecutor = context.WebRequestExecutorFactory.CreateWebRequestExecutor(context, url);
//HttpWebRequest request = webrequestexecutor.WebRequest;
//ClientRuntimeContext.SetupRequestCredential(context, request);
//var FireExecutingWebRequestEventInternalMethod = typeof(ClientContext).GetMethod("FireExecutingWebRequestEventInternal",
// BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
//FireExecutingWebRequestEventInternalMethod.Invoke(context, new object[] { new WebRequestEventArgs(webrequestexecutor) });

//var result = "";
//var response = request.GetResponse();
//using (StreamReader sr = new StreamReader(response.GetResponseStream()))
//{
// result = sr.ReadToEnd();
//}

var requestStream = executor.GetRequestStream();
using (var streamWriter = new StreamWriter(requestStream, Encoding.UTF8))
using (var executor = clientContext.WebRequestExecutorFactory.CreateWebRequestExecutor(clientContext, publishUrl))
{
var formatedString = BuildSoapRequest(list, WorkflowModel);
streamWriter.Write(formatedString);
executor.RequestMethod = "POST";
executor.RequestContentType = "text/xml; charset=utf-8";
executor.RequestHeaders.Add("X-RequestDigest", formDigestValue);
executor.RequestHeaders.Add("SOAPAction", "\"http://nintex.com/PublishFromNWFXml\"");
executor.RequestHeaders.Add(HttpRequestHeader.AcceptEncoding, "gzip, deflate");
executor.WebRequest.AutomaticDecompression = DecompressionMethods.GZip;

HttpWebRequest request = executor.WebRequest;
ClientRuntimeContext.SetupRequestCredential(clientContext, request);
var FireExecutingWebRequestEventInternalMethod = typeof(ClientContext).GetMethod("FireExecutingWebRequestEventInternal",
BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic);
FireExecutingWebRequestEventInternalMethod.Invoke(clientContext, new object[] { new WebRequestEventArgs(executor) });

var requestStream = executor.GetRequestStream();
using (var streamWriter = new StreamWriter(requestStream, Encoding.UTF8))
{
var formatedString = BuildSoapRequest(list, WorkflowModel);
streamWriter.Write(formatedString);
}
requestStream.Close();

var result = "";
var response = request.GetResponse();
using (StreamReader sr = new StreamReader(response.GetResponseStream()))
{
result = sr.ReadToEnd();
result = ReadSoapResponse(result);
}


//executor.Execute();

//var result = ReadSoapResponse(executor);

InvokeOnModelEvent(this, new ModelEventArgs
{
CurrentModelNode = null,
Model = null,
EventType = ModelEventType.OnProvisioned,
Object = result,
ObjectType = typeof(string),
ObjectDefinition = WorkflowModel,
ModelHost = modelHost
});
}
requestStream.Close();

executor.Execute();

var result = ReadSoapResponse(executor);

InvokeOnModelEvent(this, new ModelEventArgs
{
CurrentModelNode = null,
Model = null,
EventType = ModelEventType.OnProvisioned,
Object = result,
ObjectType = typeof(string),
ObjectDefinition = WorkflowModel,
ModelHost = modelHost
});
}

private string BuildSoapRequest(List list, NintexWorkflowDefinition workflowModel)
Expand All @@ -135,6 +135,10 @@ private string ReadSoapResponse(WebRequestExecutor requestExecutor)
{
soapResponse = sr.ReadToEnd();
}
return ReadSoapResponse(soapResponse);
}
private string ReadSoapResponse(string soapResponse)
{
XmlDocument document = new XmlDocument();
document.LoadXml(soapResponse);
XmlNamespaceManager manager = new XmlNamespaceManager(document.NameTable);
Expand Down

0 comments on commit f123500

Please sign in to comment.