v0.13.0

Author: mx2s

.circleci/config.json.testing

@@ -0,0 +1,23 @@
+{
+    "database": {
+    	"host": "localhost",
+        "name": "openhub_api_test",
+        "user": "postgres",
+        "port": 5432,
+        "password": ""
+    },
+    "auth": {
+        "encryption_key": "FDj1j322fDFJ2ivbrajhw",
+        "jwt": {
+            "secret_key": "GQDsD21j8s2zdm12F1f1k12",
+            "token_life_days": 7
+        }
+    },
+    "Logging": {
+        "LogLevel": {
+            "Default": "Debug",
+            "System": "Information",
+            "Microsoft": "Information"
+        }
+    }
+}

.circleci/config.yml

@@ -0,0 +1,81 @@
+version: 2
+jobs:
+  build:
+    working_directory: ~/repo
+    docker:
+    - image: centos:7
+
+    steps:
+      - checkout
+
+      - run:
+          name: ls
+          command: ls
+
+      - run:
+          name: install git & postgres & sudo
+          command: yum install -y git postgresql postgresql-server sudo
+
+      - run:
+          name: Install initscripts to be able to work with services
+          command: yum install -y initscripts && yum clean all
+
+      - run:
+          name: Add .net core repo
+          command: rpm -Uvh https://packages.microsoft.com/config/rhel/7/packages-microsoft-prod.rpm
+
+      - run:
+          name: yum update
+          command: yum update -y
+
+      - run:
+          name: install php deps
+          command: yum -y install http://rpms.remirepo.net/enterprise/remi-release-7.rpm && yum -y install epel-release yum-utils && yum-config-manager --disable remi-php54 && yum-config-manager --enable remi-php73
+
+      - run:
+          name: install php 
+          command: yum -y install php php-cli php-zip wget unzip php-pgsql
+
+      - run:
+          name: php version
+          command: php -v
+
+      - run:
+          name: install composer
+          command: curl -sS https://getcomposer.org/installer -o composer-setup.php && php composer-setup.php --install-dir=/usr/local/bin --filename=composer
+
+      - run:
+          name: composer version
+          command: composer --version
+
+      - run:
+          name: copy phinx config
+          command: cp .circleci/phinx.yml.testing migrations/phinx.yml
+
+      - run:
+          name: set up postgres
+          command: sudo -u postgres /usr/bin/initdb /var/lib/pgsql/data/ && sudo -u postgres /usr/bin/pg_ctl start -D /var/lib/pgsql/data -s -o "-p 5432" -w -t 300
+
+      - run:
+          name: create database
+          command: sudo -u postgres psql -c 'create database openhub_api_test;'
+
+      - run:
+          name: composer install & migrate
+          command: (cd migrations && composer install) && (cd migrations && php vendor/bin/phinx migrate -e testing)
+
+      - run:
+          name: copy app config
+          command: mkdir -p Tests/bin/Debug/netcoreapp2.2/config && cp .circleci/config.json.testing Tests/bin/Debug/netcoreapp2.2/config/config.json
+
+      - run:
+          name: yum install dotnet core sdk 2.2
+          command: yum install -y dotnet-sdk-2.2
+
+      - run:
+          name: build
+          command: dotnet build
+
+      - run:
+          name: run tests
+          command: dotnet test

.circleci/phinx.yml.testing

@@ -0,0 +1,17 @@
+paths:
+    migrations: '%%PHINX_CONFIG_DIR%%/db/migrations'
+    seeds: '%%PHINX_CONFIG_DIR%%/db/seeds'
+
+environments:
+    default_migration_table: phinxlog
+    default_database: testing
+    testing:
+        adapter: pgsql
+        host: localhost
+        name: openhub_api_test
+        user: postgres
+        pass: ''
+        port: 5432
+        charset: utf8
+
+version_order: creation

App/AL/AppBoot.cs

@@ -0,0 +1,14 @@
+using System;
+using App.DL.Module.Cache;
+
+namespace App.AL {
+    public static class AppBoot {
+        public static void Boot() {
+            Console.WriteLine("Booting...");
+            
+            ModelCache.StartAutoResetTask();
+            
+            Console.WriteLine("Boot finished.");
+        }
+    }
+}

App/AL/CLI/Finding/ApproveInvoice.cs

@@ -0,0 +1,79 @@
+using System;
+using System.Collections.Generic;
+using App.AL.Utils.Funding;
+using App.DL.Enum;
+using App.DL.Model.Funding;
+using App.DL.Repository.User;
+using App.PL.Transformer.Funding;
+using App.PL.Transformer.User;
+using Micron.AL.Config.CLI;
+using Micron.DL.Module.CLI;
+using Newtonsoft.Json.Linq;
+
+namespace App.AL.CLI.Finding {
+    public class ApproveInvoice : BaseCommand, ICliCommand {
+        public override string Signature { get; } = "approve-invoice";
+
+        public ApproveInvoice() {
+            StrOutput = new List<string>();
+        }
+
+        public CliResult Execute() {
+            Output("Approving invoice");
+            Output("Type invoice id:");
+            
+            var id = Convert.ToInt32(Console.ReadLine());
+            var invoice = Invoice.Find(id);
+            if (invoice == null) {
+                Output($"Invoice with id {id} not found");
+                return new CliResult(CliExitCode.NotFound, StrOutput);
+            }
+            
+            Output("Invoice:");
+            Output(JObject.FromObject(invoice).ToString());
+            Output("Transformed invoice:");
+            Output(new InvoiceTransformer().Transform(invoice).ToString());
+            Output("Invoice user:");
+            Output(JObject.FromObject(invoice.User()).ToString());
+
+            if (invoice.status != InvoiceStatus.RequiresConfirmation) {
+                Output("Invoice has invalid status - allowed only: " + InvoiceStatus.RequiresConfirmation);
+                return new CliResult(CliExitCode.UnknownError, StrOutput);
+            } 
+
+            var isApproving = Ask("Approve that invoice?");
+            
+            if (!isApproving) {
+                Output("Aborted.");
+                return new CliResult(CliExitCode.Ok, StrOutput);
+            }
+            
+            Output("Approving invoice...");
+
+            invoice = InvoiceUtils.ConfirmInvoice(invoice);
+            
+            var isProcessing = Ask("Process confirmed invoice?");
+
+            if (!isProcessing) {
+                return new CliResult(CliExitCode.Ok, StrOutput);
+            }
+
+            var balance = UserBalanceRepository.Find(invoice.User());
+            
+            Output("Balance before:");
+            Output(new UserBalanceTransformer().Transform(balance).ToString());
+            
+            Output("Processing invoice...");
+            invoice = InvoiceUtils.ProcessConfirmedInvoice(invoice);
+            Output("Invoice processing finished...");
+            
+            Output("Balance after:");
+            Output(new UserBalanceTransformer().Transform(balance.Refresh()).ToString());
+            
+            Output("Transformed invoice:");
+            Output(new InvoiceTransformer().Transform(invoice).ToString());
+
+            return new CliResult(CliExitCode.Ok, StrOutput);
+        }
+    }
+}

App/AL/Config/CLI/CommandsList.cs

@@ -0,0 +1,13 @@
+using App.AL.CLI.Finding;
+using Micron.AL.CLI.Basic;
+using Micron.DL.Module.CLI;
+
+namespace App.AL.Config.CLI {
+    public static class CommandsList {
+        public static ICliCommand[] Get()
+            => new ICliCommand[] {
+                new PrintFrameworkVersion(),
+                new ApproveInvoice()
+            };
+    }
+}

App/AL/Config/Funding/InvoiceConfig.cs

@@ -0,0 +1,5 @@
+namespace App.AL.Config.Funding {
+    public static class InvoiceConfig {
+        public const int UserActiveInvoicesLimit = 10;
+    }
+}

App/AL/Config/UserSetting/AllowedValues.cs

@@ -0,0 +1,14 @@
+using System.Collections.Generic;
+
+namespace App.AL.Config.UserSetting {
+    public static class AllowedValues {
+        // equal null means that all values are allowed
+        public static Dictionary<string, string[]> GetAllowed()
+            => new Dictionary<string, string[]> {
+                ["subscription_currency"] = new[] {
+                    "Usd", "BitCoin", "Ethereum", "Erc20Token", "Waves", "WavesToken", "LiteCoin"
+                },
+                ["subscription_amount"] = null
+            };
+    }
+}

App/AL/Controller/Alias/Project/ProjectAliasController.cs

@@ -0,0 +1,35 @@
+using App.DL.Repository.Alias;
+using App.PL.Transformer.Project;
+using Micron.AL.Validation.Basic;
+using Micron.DL.Middleware;
+using Micron.DL.Module.Controller;
+using Micron.DL.Module.Http;
+using Micron.DL.Module.Validator;
+using Nancy;
+
+namespace App.AL.Controller.Alias.Project {
+    public class ProjectAliasController : BaseController {
+        protected override IMiddleware[] Middleware() => new IMiddleware[] { };
+
+        public ProjectAliasController() {
+            Get("/api/v1/alias/project/get", _ => {
+                var errors = ValidationProcessor.Process(Request, new IValidatorRule[] {
+                    new ShouldHaveParameters(new[] {"owner", "alias"})
+                });
+                if (errors.Count > 0) {
+                    return HttpResponse.Errors(errors);
+                }
+
+                var alias = ProjectAliasRepository.FindByAlias(
+                    GetRequestStr("owner"), GetRequestStr("alias")
+                );
+
+                if (alias == null) {
+                    return HttpResponse.Error(HttpStatusCode.NotFound, "Project not found");
+                }
+                
+                return HttpResponse.Item("project", new ProjectTransformer().Transform(alias.Project()));
+            });
+        }
+    }
+}

App/AL/Controller/Auth/External/Facebook/FacebookAuthController.cs

@@ -0,0 +1,53 @@
+using System.Net.Http;
+using App.DL.Enum;
+using App.DL.Repository.Auth;
+using App.DL.Repository.User;
+using Micron.AL.Validation.Basic;
+using Micron.DL.Middleware;
+using Micron.DL.Module.Auth;
+using Micron.DL.Module.Controller;
+using Micron.DL.Module.Http;
+using Micron.DL.Module.Validator;
+using Nancy;
+using Newtonsoft.Json.Linq;
+
+namespace App.AL.Controller.Auth.External.Facebook {
+    public class FacebookAuthController : BaseController {
+        private const string ApiUrl = "https://graph.facebook.com/v2.3/";
+        
+        protected override IMiddleware[] Middleware() => new IMiddleware[] { };
+
+        public FacebookAuthController() {
+            Get("/api/v1/auth/facebook/my_token/get", _ => {
+                var errors = ValidationProcessor.Process(Request, new IValidatorRule[] {
+                    new ShouldHaveParameters(new[] {"facebook_token"}),
+                });
+                if (errors.Count > 0) {
+                    return HttpResponse.Errors(errors);
+                }
+
+                var facebookToken = GetRequestStr("facebook_token");
+                
+                var response = new HttpClient().GetAsync(
+                    ApiUrl + $"me?access_token={facebookToken}&fields=name,email"
+                ).Result;
+                if (!response.IsSuccessStatusCode) {
+                    return HttpResponse.Error(HttpStatusCode.BadRequest, "Invalid facebook token");
+                }
+                var json = JObject.Parse(response.Content.ReadAsStringAsync().Result);
+
+                var email = json.Value<string>("email");
+                var login = email.Split("@")[0];
+
+                var user = UserRepository.FindByEmail(email) ?? UserRepository.FindOrCreateByEmailAndLogin(email, login);
+
+                var accessToken = ServiceAccessTokenRepository.FindOrUpdateAccessToken(user, facebookToken, ServiceType.Facebook);
+                accessToken.UpdateCol("origin_user_id", json.Value<string>("id"));
+
+                return HttpResponse.Data(new JObject() {
+                    ["token"] = Jwt.FromUserId(user.id)
+                });
+            });
+        }
+    }
+}