Added usage examples
* Cleaned up project.json * Updated README with example on how to deserialize json request body * Added reference to System.Runtime.Serialization.Json as this would seems a common usage * Added C# example files to the /Examples directory
This commit is contained in:
@@ -26,7 +26,8 @@ namespace Fission.DotNetCore.Compiler
|
|||||||
{
|
{
|
||||||
MetadataReference.CreateFromFile(coreDir.FullName + Path.DirectorySeparatorChar + "mscorlib.dll"),
|
MetadataReference.CreateFromFile(coreDir.FullName + Path.DirectorySeparatorChar + "mscorlib.dll"),
|
||||||
MetadataReference.CreateFromFile(typeof(object).GetTypeInfo().Assembly.Location),
|
MetadataReference.CreateFromFile(typeof(object).GetTypeInfo().Assembly.Location),
|
||||||
MetadataReference.CreateFromFile(Assembly.GetEntryAssembly().Location)
|
MetadataReference.CreateFromFile(Assembly.GetEntryAssembly().Location),
|
||||||
|
MetadataReference.CreateFromFile(typeof(System.Runtime.Serialization.Json.DataContractJsonSerializer).GetTypeInfo().Assembly.Location)
|
||||||
};
|
};
|
||||||
|
|
||||||
foreach (var referencedAssembly in Assembly.GetEntryAssembly().GetReferencedAssemblies())
|
foreach (var referencedAssembly in Assembly.GetEntryAssembly().GetReferencedAssemblies())
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ using System;
|
|||||||
using System.Collections.Generic;
|
using System.Collections.Generic;
|
||||||
using System.IO;
|
using System.IO;
|
||||||
using System.Security.Cryptography.X509Certificates;
|
using System.Security.Cryptography.X509Certificates;
|
||||||
|
using System.Text;
|
||||||
using Nancy;
|
using Nancy;
|
||||||
|
|
||||||
namespace Fission.DotNetCore.Api
|
namespace Fission.DotNetCore.Api
|
||||||
@@ -84,6 +85,15 @@ namespace Fission.DotNetCore.Api
|
|||||||
}
|
}
|
||||||
|
|
||||||
public Stream Body { get { return _request.Body; } }
|
public Stream Body { get { return _request.Body; } }
|
||||||
|
|
||||||
|
public string BodyAsString()
|
||||||
|
{
|
||||||
|
int length = (int)_request.Body.Length;
|
||||||
|
byte[] data = new byte[length];
|
||||||
|
_request.Body.Read(data, 0, length);
|
||||||
|
return Encoding.UTF8.GetString(data);
|
||||||
|
}
|
||||||
|
|
||||||
public Dictionary<string, IEnumerable<string>> Headers
|
public Dictionary<string, IEnumerable<string>> Headers
|
||||||
{
|
{
|
||||||
get
|
get
|
||||||
|
|||||||
@@ -163,7 +163,7 @@ $ curl "http://$FISSION_ROUTER/add?x=30&y=12"
|
|||||||
42
|
42
|
||||||
```
|
```
|
||||||
|
|
||||||
## Accessing Http request information example
|
## Accessing http request information example
|
||||||
|
|
||||||
### Setup fission environment
|
### Setup fission environment
|
||||||
First you need to setup the fission according to your cluster setup as
|
First you need to setup the fission according to your cluster setup as
|
||||||
@@ -216,6 +216,60 @@ Url: http://fissionserver:8888, method: GET
|
|||||||
|
|
||||||
```
|
```
|
||||||
|
|
||||||
|
## Accessing http request body example
|
||||||
|
|
||||||
|
### Setup fission environment
|
||||||
|
First you need to setup the fission according to your cluster setup as
|
||||||
|
specified here: https://github.com/fission/fission
|
||||||
|
|
||||||
|
|
||||||
|
### Create the class to run
|
||||||
|
|
||||||
|
Secondly you need to create a file /tmp/func.cs containing the following code:
|
||||||
|
|
||||||
|
```
|
||||||
|
using System.IO;
|
||||||
|
using System.Runtime.Serialization.Json;
|
||||||
|
using Fission.DotNetCore.Api;
|
||||||
|
|
||||||
|
public class FissionFunction
|
||||||
|
{
|
||||||
|
public string Execute(FissionContext context)
|
||||||
|
{
|
||||||
|
var person = Person.Deserialize(context.Request.Body);
|
||||||
|
return $"Hello, my name is {person.Name} and I am {person.Age} years old.";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public class Person
|
||||||
|
{
|
||||||
|
public string Name { get; set; }
|
||||||
|
public int Age { get; set; }
|
||||||
|
|
||||||
|
public static Person Deserialize(Stream json)
|
||||||
|
{
|
||||||
|
var serializer = new DataContractJsonSerializer(typeof(Person));
|
||||||
|
return (Person)serializer.ReadObject(json);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
```
|
||||||
|
### Run the example
|
||||||
|
|
||||||
|
Lastly to run the example:
|
||||||
|
|
||||||
|
```
|
||||||
|
$ fission env create --name dotnet --image fission/dotnet-env
|
||||||
|
|
||||||
|
$ fission function create --name httpbody --env dotnet --code /tmp/func.cs
|
||||||
|
|
||||||
|
$ fission route create --method GET --url /http_body --function httpbody
|
||||||
|
|
||||||
|
$ curl -XPOST "http://$FISSION_ROUTER/http_body" -d '{ "Name":"Arthur", "Age":42}'
|
||||||
|
Hello, my name is Arthur and I am 42 years old.
|
||||||
|
|
||||||
|
```
|
||||||
|
|
||||||
|
|
||||||
## Developing/debugging the enviroment locally
|
## Developing/debugging the enviroment locally
|
||||||
|
|
||||||
|
|||||||
@@ -1,24 +1,24 @@
|
|||||||
{
|
{
|
||||||
"version": "1.0.0-*",
|
"version": "1.0.0-*",
|
||||||
"buildOptions": {
|
"buildOptions": {
|
||||||
"emitEntryPoint": true,
|
"emitEntryPoint": true,
|
||||||
"outputName": "fission-dotnet"
|
"outputName": "fission-dotnet"
|
||||||
},
|
|
||||||
|
|
||||||
"dependencies": {
|
|
||||||
"Microsoft.NETCore.App": {
|
|
||||||
"version": "1.1.0",
|
|
||||||
"type": "platform"
|
|
||||||
},
|
|
||||||
"Microsoft.AspNetCore.Server.Kestrel": "1.0.0",
|
|
||||||
"Microsoft.AspNetCore.Owin": "1.0.0",
|
|
||||||
"Nancy": "2.0.0-barneyrubble",
|
|
||||||
"Microsoft.CodeAnalysis.CSharp": "1.3.0-*",
|
|
||||||
"System.Runtime.Loader": "4.0.0-*",
|
|
||||||
},
|
},
|
||||||
"frameworks": {
|
"frameworks": {
|
||||||
"netcoreapp1.0": {
|
"netcoreapp1.0": {
|
||||||
"imports": "dnxcore50"
|
"dependencies": {
|
||||||
|
"Microsoft.NETCore.App": {
|
||||||
|
"version": "1.1.0",
|
||||||
|
"type": "platform"
|
||||||
|
},
|
||||||
|
"Microsoft.AspNetCore.Server.Kestrel": "1.0.0",
|
||||||
|
"Microsoft.AspNetCore.Owin": "1.0.0",
|
||||||
|
"Nancy": "2.0.0-barneyrubble",
|
||||||
|
"Microsoft.CodeAnalysis.CSharp": "1.3.0-*",
|
||||||
|
"System.Runtime.Loader": "4.0.0-*",
|
||||||
|
"System.Runtime.Serialization.Json": "4.0.2"
|
||||||
|
},
|
||||||
|
"imports": "netstandard1.3"
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
}
|
}
|
||||||
@@ -0,0 +1,11 @@
|
|||||||
|
using System;
|
||||||
|
using Fission.DotNetCore.Api;
|
||||||
|
|
||||||
|
public class FissionFunction
|
||||||
|
{
|
||||||
|
public string Execute(FissionContext context){
|
||||||
|
var x = Convert.ToInt32(context.Arguments["x"]);
|
||||||
|
var y = Convert.ToInt32(context.Arguments["y"]);
|
||||||
|
return (x+y).ToString();
|
||||||
|
}
|
||||||
|
|
||||||
@@ -0,0 +1,9 @@
|
|||||||
|
using Fission.DotNetCore.Api;
|
||||||
|
|
||||||
|
public class FissionFunction
|
||||||
|
{
|
||||||
|
public string Execute(FissionContext context)
|
||||||
|
{
|
||||||
|
return "Hello World!";
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,24 @@
|
|||||||
|
using System.IO;
|
||||||
|
using System.Runtime.Serialization.Json;
|
||||||
|
using Fission.DotNetCore.Api;
|
||||||
|
|
||||||
|
public class FissionFunction
|
||||||
|
{
|
||||||
|
public string Execute(FissionContext context)
|
||||||
|
{
|
||||||
|
var person = Person.Deserialize(context.Request.Body);
|
||||||
|
return $"Hello, my name is {person.Name} and I am {person.Age} years old.";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
public class Person
|
||||||
|
{
|
||||||
|
public string Name { get; set; }
|
||||||
|
public int Age { get; set; }
|
||||||
|
|
||||||
|
public static Person Deserialize(Stream json)
|
||||||
|
{
|
||||||
|
var serializer = new DataContractJsonSerializer(typeof(Person));
|
||||||
|
return (Person)serializer.ReadObject(json);
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,17 @@
|
|||||||
|
using System;
|
||||||
|
using Fission.DotNetCore.Api;
|
||||||
|
|
||||||
|
public class FissionFunction
|
||||||
|
{
|
||||||
|
public string Execute(FissionContext context){
|
||||||
|
var buffer = new System.Text.StringBuilder();
|
||||||
|
foreach(var header in context.Request.Headers){
|
||||||
|
buffer.AppendLine(header.Key);
|
||||||
|
foreach(var item in header.Value){
|
||||||
|
buffer.AppendLine($"\t{item}");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
buffer.AppendLine($"Url: {context.Request.Url}, method: {context.Request.Method}");
|
||||||
|
return buffer.ToString();
|
||||||
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user