From 496eb3a4252dce5e37c735b47b30927d1aa85a18 Mon Sep 17 00:00:00 2001
From: Aryadev Chavali <aryadevchavali1@gmail.com>
Date: Mon, 25 Feb 2019 11:37:20 +0000
Subject: Made it take a string for configuration and accessing database
---
Main/Jobs/AggregatorJob.cs | 17 ++++++++++++-----
1 file changed, 12 insertions(+), 5 deletions(-)
diff --git a/Main/Jobs/AggregatorJob.cs b/Main/Jobs/AggregatorJob.cs
index eec9aff..065a1f0 100644
--- a/Main/Jobs/AggregatorJob.cs
+++ b/Main/Jobs/AggregatorJob.cs
@@ -2,12 +2,15 @@ using System.Linq;
using System.Threading.Tasks;
using System.Collections.Generic;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.EntityFrameworkCore;
+
using Classes;
using Database;
using Aggregator;
namespace Main.Jobs {
- public static class AggregatorJob {
+ public class AggregatorJob {
private static List<Config> configs = new List<Config> {
new Config {
Source = "BBC",
@@ -41,12 +44,16 @@ namespace Main.Jobs {
"https://abcnews.go.com/abcnews/topstories"
};
- public static async Task Process(DatabaseContext context) {
- var articles = await parseMultiple();
- await context.InsertArticles(articles);
+ public async Task Start(string config) {
+ var builder = new DbContextOptionsBuilder<DatabaseContext>();
+ builder.UseMySQL(config);
+ using (var context = new DatabaseContext(builder.Options)) {
+ var articles = await parseMultiple();
+ await context.InsertArticles(articles);
+ }
}
- private static async Task<List<Article>> parseMultiple() {
+ private async Task<List<Article>> parseMultiple() {
var xmls = new List<string>();
foreach (string site in sites) {
xmls.Add(await Download.DownloadXML(site));
--
cgit v1.2.3-13-gbd6f