Add a conversion function between RawEvent and CollectorPayload

[chuwy]

... and CollectorPayload -> List[RawEvent]?

Technically, it should be almost lossless operation. This is out of scope of snowplow-badrows project, but until we have a better place for these payloads, I think we can leave it.

/cc @peel @benjben

[benjben]

Is there another place that the recovery job where we would want to do that?

[chuwy]

That's a good question. It feels that we might want to do it in SCE.

[chuwy]

Closed by mistake.

[lukeindykiewicz]

Some hints from Anton:

case class CollectorPayload(
  vendor: String,                     // +
  version: String,                    // +
  querystring: List[NVP],             // Possibly empty. If not empty, body is `None` (it was GET request)
  contentType: Option[String],        // +
  body: Option[String],               // Possibly `None`. If `Some`, contentType is empty (it was POST request)
  collector: String,                  // +
  encoding: String,                   // +
  hostname: Option[String],           // +
  timestamp: Option[DateTime],        // +
  ipAddress: Option[String],          // +
  useragent: Option[String],          // +
  refererUri: Option[String],         // +
  headers: List[String],              // +
  networkUserId: Option[UUID]         // +
)
case class RawEvent(
  vendor: String,                     // + 
  version: String,                    // +
  parameters: Map[String, String],    // Either querystring.toList or body.flatMap(parseJson).flatMap(_.asObject).getOrElse(Map.empty)
  contentType: Option[String],        // +
  loaderName: String,                 // ???
  encoding: String,                   // +
  hostname: Option[String],           // +
  timestamp: Option[DateTime],        // +
  ipAddress: Option[String],          // +
  useragent: Option[String],          // +
  refererUri: Option[String],         // +
  headers: List[String],              // +
  userId: Option[UUID]                // +
)

Everything with + is just a direct mapping