User-1849651236 posted
Thanks for your help with this. Here is my whole controller:
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
using Microsoft.EntityFrameworkCore;
using ChinavasionAPI.Data;
using ChinavasionAPI.Models;
using ChinavasionAPI.Models.CAPIViewModels;
using ChinavasionAPI.Managers;
using ChinavasionAPI.Parameters;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc.Rendering;using Newtonsoft.Json;
using Microsoft.AspNetCore.Http;
namespace ChinavasionAPI.Controllers
{
public class APIController : Controller
{
private readonly ChinavasionAPIContext _context;
public APIController(ChinavasionAPIContext context)
{
_context = context;
}
public IActionResult Index()
{
return View();
}
[HttpGet]
public async Task<IActionResult> Process()
{
var viewModel = new SetupIndexData();
viewModel.Setups = await _context.Setups.ToListAsync();
return View(viewModel);
}
[HttpPost]
public async Task<IActionResult> Process(IFormCollection formCollection, string parameterName, string parameterValue)
{
string serverUrl = formCollection["SetupText"].ToString();
string queryCall = formCollection["QueryCallText"].ToString();
int? setupID = Convert.ToInt16(formCollection["SetupID"]);
if (setupID == null)
{
return NotFound();
}
var setup = await _context.Setups
.SingleOrDefaultAsync(m => m.ID == setupID);
if (setup == null)
{
return NotFound();
}
string serverKey = setup.Key;
var model = new AccessModel();
model.UserAccessModel = _context.UserAccessModels.Single(a => a.ID == 1);
ViewBag.SyncOrAsync = "Asynchronous";
var productsService = new Service.ProductService();
List<Product> products = (await productsService.ProcessAPIAsync(serverUrl, serverKey, queryCall, parameterName, parameterValue));
if (ModelState.IsValid)
{
try
{
var nopAuthorizationManager = new AuthorizationManager(model.UserAccessModel.ClientId, model.UserAccessModel.ClientSecret, model.UserAccessModel.ServerUrl);
var redirectUrl = Url.RouteUrl("GetAccessToken", null, Request.Scheme);
if (redirectUrl != model.UserAccessModel.RedirectUrl)
{
return BadRequest();
}
// This should not be saved anywhere.
var state = Guid.NewGuid();
//Session["state"] = state;
string authUrl = nopAuthorizationManager.BuildAuthUrl(redirectUrl, new string[] { }, state.ToString());
return Redirect(authUrl);
}
catch (Exception ex)
{
return BadRequest(ex.Message);
}
}
return BadRequest();
//return View("~/Views/Home/Products.cshtml", submitMethod.Submit(model.UserAccessModel));
}
[HttpGet]
[AllowAnonymous]
public ActionResult GetAccessToken(string code, string state)
{
if (ModelState.IsValid && !string.IsNullOrEmpty(code) && !string.IsNullOrEmpty(state))
{
var model = new AccessModel();
model.UserAccessModel = _context.UserAccessModels.Single(a => a.ID == 1);
try
{
string clientId = model.UserAccessModel.ClientId;
string clientSecret = model.UserAccessModel.ClientSecret;
string serverUrl = model.UserAccessModel.ServerUrl;
string redirectUrl = model.UserAccessModel.RedirectUrl;
var authParameters = new AuthParameters()
{
ClientId = clientId,
ClientSecret = clientSecret,
ServerUrl = serverUrl,
RedirectUrl = redirectUrl,
GrantType = "authorization_code",
Code = code
};
var nopAuthorizationManager = new AuthorizationManager(authParameters.ClientId, authParameters.ClientSecret, authParameters.ServerUrl);
string responseJson = nopAuthorizationManager.GetAuthorizationData(authParameters);
AuthorizationModel authorizationModel = JsonConvert.DeserializeObject<AuthorizationModel>(responseJson);
model.AuthorizationModel = authorizationModel;
model.UserAccessModel = new UserAccessModel()
{
ClientId = clientId,
ClientSecret = clientSecret,
ServerUrl = serverUrl,
RedirectUrl = redirectUrl
};
// TODO: Here you can save your access and refresh tokens in the database. For illustration purposes we will save them in the Session and show them in the view.
//Session["accessToken"] = authorizationModel.AccessToken;
model.UserAccessModel.AccessToken = authorizationModel.AccessToken;
}
catch (Exception ex)
{
return BadRequest(ex.Message);
}
return View("~/Views/API/AccessToken.cshtml", model);
}
return BadRequest();
}
[HttpGet]
[AllowAnonymous]
public JsonResult RefreshAccessToken(string refreshToken, string clientId, string clientSecret, string serverUrl)
{
string json = string.Empty;
if (ModelState.IsValid &&
!string.IsNullOrEmpty(refreshToken) &&
!string.IsNullOrEmpty(clientId) &&
!string.IsNullOrEmpty(clientSecret) &&
!string.IsNullOrEmpty(serverUrl))
{
var model = new AccessModel();
try
{
var authParameters = new AuthParameters()
{
ClientId = clientId,
ClientSecret = clientSecret,
ServerUrl = serverUrl,
RefreshToken = refreshToken,
GrantType = "refresh_token"
};
var nopAuthorizationManager = new AuthorizationManager(authParameters.ClientId,
authParameters.ClientSecret, authParameters.ServerUrl);
string responseJson = nopAuthorizationManager.RefreshAuthorizationData(authParameters);
AuthorizationModel authorizationModel =
JsonConvert.DeserializeObject<AuthorizationModel>(responseJson);
model.AuthorizationModel = authorizationModel;
model.UserAccessModel = new UserAccessModel()
{
ClientId = clientId,
ServerUrl = serverUrl
};
// Here we use the temp data because this method is called via ajax and here we can't hold a session.
// This is needed for the GetCustomers method in the CustomersController.
TempData["accessToken"] = authorizationModel.AccessToken;
TempData["serverUrl"] = serverUrl;
}
catch (Exception ex)
{
json = string.Format("error: '{0}'", ex.Message);
//return Json(json, JsonRequestBehavior.AllowGet);
return Json(json);
}
json = JsonConvert.SerializeObject(model.AuthorizationModel);
}
else
{
json = "error: 'something went wrong'";
}
return Json(json);
}
private ActionResult BadRequest(string message = "Bad Request")
{
//return new HttpStatusCodeResult(HttpStatusCode.BadRequest, message);
return new StatusCodeResult(404);
}
}
}
Thanks,
Tony
