Notes

using Jsi.DataCollection.DataContracts;
using Jsi.DataCollection.DataContracts.Data;
using System;
using System.Collections.Generic;
using System.ComponentModel.Composition;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace SampleCdrLoader
{
[Export(typeof(IDataCollectionComponent))]
public class SampleCdrLoader : IDataCollectionComponent
{
/// <summary>
/// Loader name
/// </summary>
public string Name => "Sample CDR Loader";

/// <summary>
/// Helper method to read csv files
/// </summary>
/// <param name="path">Path to the files</param>
/// <returns>A list of lines, each line is a list of strings</returns>
public static List<List<string>> GetLines(string path)
{
var lines = new List<List<string>>();

foreach (var line in File.ReadAllLines(path))
{
lines.Add(line.Split(',').ToList());
}

return lines;
}

/// <summary>
/// Checks if loader can process the given file
/// </summary>
/// <param name="filePath">The path to the file</param>
/// <param name="workingDirectory">Working directory to use</param>
/// <returns>True if file can be processed, false otherwise</returns>
public bool CanHandle(string filePath, string workingDirectory)
{
if (filePath.EndsWith(".csv", StringComparison.OrdinalIgnoreCase))
{
// Get the header line
var firstLine = GetLines(filePath).First();

return
firstLine.Count == 7 && // Make sure there are exactly 7 coloumns
firstLine[0] == "Timestamp" &&
firstLine[1] == "Target Number" &
firstLine[2] == "Associate Number" &&
firstLine[3] == "Type" &&
firstLine[4] == "Direction" &&
firstLine[5] == "Duration" &&
firstLine[6] == "Text";
}
//TODO: Implement this method. It should return true if file is a .#.sample.csv with expected
// headers, # is your student number
throw new NotImplementedException();
}

/// <summary>
/// Import a file. Create and upload sessions from the given file
/// </summary>
/// <param name="filePath">Path to the file</param>
/// <param name="workingDirectory">Working directory to use</param>
/// <param name="context">Provides functionality required to create and upload sessions</param>
public void Import(string filePath, string workingDirectory, IImportContext context)
{
foreach (var line in GetLines(filePath))
{
if (line[0] != "Timestamp"){
var session = context.CreateSession(Name, null, false);
session.StartTime = DateTime.Parse(line[0]);
if (line[3] == "sms")
{
session.SetSessionType(SessionTypes.Sms);
session.SetSessionType("text/plain");
session.SetPreview(line[6]);
session.DisplayTypeID = SessionDisplayType.CcrSms;
}
else
{
session.SetSessionType(SessionTypes.Telephony);
session.DurationInSeconds = (int)TimeSpan.Parse(line[5]).TotalSeconds;
session.DisplayTypeID = SessionDisplayType.CcrVoice;
}


if (line[4] == "out")
{
session.SetDirection(Directions.Outgoing);

var inv = context.CreateInvolvement(InvolvementRoles.From, true);
inv.Msisdn = line[1];
session.AddInvolvement(inv);

var inv2 = context.CreateInvolvement(InvolvementRoles.To, false);
inv2.Msisdn = line[2];
session.AddInvolvement(inv2);
} else
{
session.SetDirection(Directions.Incoming);
var inv = context.CreateInvolvement(InvolvementRoles.From, false);
inv.Msisdn = line[2];
session.AddInvolvement(inv);

var inv2 = context.CreateInvolvement(InvolvementRoles.To, true);
inv2.Msisdn = line[1];
session.AddInvolvement(inv2);
}

context.UploadSession(session);
}
}




//TODO: Implement this method. This is where we create and upload sessions
throw new NotImplementedException();
}
}
}