fchabouis

Oban

Objectif

Lancer via Oban un job de conversion d'un GTFS en GeoJson.

On passe l'url du GTFS au worker. Celui ci le télécharge et le convertit en GeoJson, le sauvegarde dans un fichier et notifie le process principal lorsqu'il a terminé en lui indiquant l'emplacement du résultat.

fchabouis

Mix.install([
  {:ecto_sql, "~> 3.7.0"},
  {:postgrex, "~> 0.15.0"},
  {:httpoison, ">= 0.0.0"},
  {:jason, ">= 0.0.0"}
])

require Logger

# SETUP DATABASE, THANKS TO https://github.com/wojtekmach/mix_install_examples

fchabouis

{
  "type": "FeatureCollection",
  "features": [
    {
      "geometry": {
        "coordinates": [
          -0.325292095610137,
          47.8370966038058
        ],
        "type": "Point"

fchabouis

// This example is meant to show how to automatically generate a json error response when something goes wrong.
use std::fmt::{Display, Formatter, Result as FmtResult};
use std::io;

use actix_web::http::StatusCode;
use actix_web::{get, web, App, HttpServer, ResponseError};
use serde::Serialize;
use serde_json::{json, to_string_pretty};

// We create a custom structure for the error

fchabouis

use actix::prelude::*;
use std::sync::Arc;

/// Define message
#[derive(Message)]
#[rtype(result = "Result<Arc<String>, std::io::Error>")]
struct WhatsYourName;

#[derive(Message)]
#[rtype(result = "()")]

fchabouis

use actix::prelude::*;

/// Define message
#[derive(Message)]
#[rtype(result = "Result<String, std::io::Error>")]
struct WhatsYourName;

#[derive(Message)]
#[rtype(result = "()")]
struct SetYourName {

fchabouis

version: 2.1
jobs:
  build_and_test:
    docker:
      - image: cypress/included:3.2.0
        environment:
          ## this enables colors in the output
          TERM: xterm
    steps:
      - checkout