1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59

public class DataServiceFactory
    {
        public static Action<Action<IDataServer, InstrumentServer>> CreateDatabaseScene()
        {
            return stuff_that_requires_database_connections =>
                       {
                           var config = new DatabaseConfiguration();
                           using (var instrument_server = CreateDB4OInstrumentServer(config.InstrumentDatabasePath.FullName))
                           using (var data_server = CreateDataServer(config.TimeSeriesDatabasePath.FullName))
                           {
                               stuff_that_requires_database_connections(data_server, instrument_server);
                           }
                       };
        }

        public static IDataServer CreateDataServer(string path)
        {
            if (!Directory.Exists(path)) Directory.CreateDirectory(path);
            return new FileDataServer(path);
        }

        public static DB40InstrumentServer CreateDB4OInstrumentServer(string path)
        {
            if (!Directory.Exists(path)) Directory.CreateDirectory(path);
            var server = new DB40InstrumentServer {DBPath = path + Path.DirectorySeparatorChar + "InstrumentDB.db4o"};
            server.Open();
            return server;
        }
    }

    public class HistoricalDataSynchronizer
    {
        private readonly IDataServer dataServer;
        private readonly InstrumentServer instrumentServer;

        public HistoricalDataSynchronizer(InstrumentServer instrumentServer, IDataServer dataServer)
        {
            this.dataServer = dataServer;
            this.instrumentServer = instrumentServer;
        }

        public void SynchronizeInstrumentsWith(HistoricalDataProvider provider)
        {
                provider.SynchronizeInstruments(new InstrumentRepository(instrumentServer),
                                                new HistoricalDataRepository(dataServer));
        }

        public void SynchronizeDataWith(HistoricalDataProvider provider)
        {
                provider.SynchronizeData(new InstrumentRepository(instrumentServer).Instruments,
                                         new HistoricalDataRepository(dataServer));
        }

        public void SynchronizeWith(HistoricalDataProvider provider)
        {
            SynchronizeInstrumentsWith(provider);
            SynchronizeDataWith(provider);
        }
    }

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

let data_server path =
  if not (Directory.Exists(path)) then Directory.CreateDirectory(path) |> ignore
  new FileDataServer(path)

let instrument_server path =
  if not (Directory.Exists(path)) then Directory.CreateDirectory(path) |> ignore
  let server = new DB40InstrumentServer(DBPath = path + Path.DirectorySeparatorChar.ToString() + "InstrumentDB.db4o")
  server.Open()
  server

let database_scene scene =
  let config = DatabaseConfiguration()
  use data = data_server config.TimeSeriesDatabasePath.FullName
  use instruments = instrument_server config.InstrumentDatabasePath.FullName
  scene instruments data 

let synchronize_instruments_with (provider: HistoricalDataProvider) instrument_server data_server  =
   provider.SynchronizeInstruments(InstrumentRepository(instrument_server), HistoricalDataRepository(data_server))

let synchronize_data_with (provider: HistoricalDataProvider) instrument_server data_server  =
   provider.SynchronizeData(InstrumentRepository(instrument_server).Instruments, HistoricalDataRepository(data_server))

let synchronize_with (provider: HistoricalDataProvider) instrument_server data_server  =
   synchronize_instruments_with provider instrument_server data_server  
   synchronize_data_with provider instrument_server data_server  

let sync =
  let what_to_sync = Sys.argv.[0]
  database_scene (fun instruments data ->
  match what_to_sync with
  | "Instruments" -> synchronize_instruments_with (CSIAPI.Create()) instruments data
  | "Data" -> synchronize_data_with (CSIAPI.Create()) instruments data
  | "All" -> synchronize_with (CSIAPI.Create()) instruments data
  | _ -> invalid_arg what_to_sync