update

* Mejor soporte de nombres que no estan en la base de datos

.gitignore

@@ -1,3 +1,4 @@
+.faaso.yml
 # Byte-compiled / optimized / DLL files
 __pycache__/
 *.py[cod]
@@ -165,3 +166,5 @@ build
 .secrets
 
 shard.lock
+
+template

README.md

@@ -9,6 +9,10 @@ En particular faas-cli (ver scripts build.sh y deploy.sh) necesita docker con bu
 
 Funciones para hacer cosas con la data de nombres de Argentina.
 
+Las que tienen prefijo `c-` están reescritas en Crystal, para practicar
+el lenguaje pero de hecho funcionan mejor que las otras y son las que están en 
+este momento en producción.
+
 Página con esto funcionando: http://nombres.ralsina.me
 
 ## tapas
@@ -16,3 +20,7 @@ Página con esto funcionando: http://nombres.ralsina.me
 Funcion para generar tapas de libros
 
 Página con esto funcionando: http://covers.ralsina.me
+
+## iol
+
+Proxy para acceder a la api de IOL de manera más sencilla.

build.sh

@@ -1,10 +0,0 @@
-#!/bin/sh -x
-set -e
-
-# My FAAS is arm64, so need to install this to cross-compile
-docker run --rm --privileged \
-  multiarch/qemu-user-static \
-  --reset -p yes
-
-faas-cli publish -f functions.yml --platforms linux/arm64 --build-arg 'TEST_ENABLED=false' $*
-faas-cli deploy -f functions.yml $*

busqueda/README.md

@@ -0,0 +1,11 @@
+# Readme for Busqueda
+
+This is a funko using the Crystal runtime for [FaaSO](https://git.ralsina.me/ralsina/faaso)
+
+## What is Busqueda
+
+Write here what it is
+
+## How to use Busqueda
+
+And so on.

busqueda/funko.cr

@@ -0,0 +1,147 @@
+require "json"
+require "kemal"
+require "db"
+require "pg"
+require "pool/connection"
+
+# get credentials from secrets
+USER   = File.read("/secrets/user").strip
+PASS   = File.read("/secrets/pass").strip
+DBHOST = File.read("/secrets/dbhost").strip
+
+DBURL = "postgres://#{USER}:#{PASS}@#{DBHOST}:5432/nombres"
+puts "Connnecting to #{DBURL}"
+
+def normalize(s : String) : String
+  s.unicode_normalize(:nfkd)
+    .chars.reject! { |character|
+    !character.ascii_letter? && (character != ' ')
+  }.join("").downcase
+end
+
+# A basic hello world get endpoint
+post "/" do |env|
+  db = DB.open DBURL
+  prefijo = env.params.json["p"].as(String)
+  genero = env.params.json["g"].as(String)
+  year = env.params.json["a"].as(String)
+
+  prefijo = normalize(prefijo)
+  if !["f", "m"].includes?(genero)
+    genero = nil
+  end
+  datos = [] of Tuple(String, Int32 | String)
+  # Connect using credentials provided
+  if prefijo.empty? && year.empty?
+    result_set = db.query("
+        SELECT nombre, total::integer
+        FROM totales
+        ORDER BY total DESC
+        LIMIT 50")
+  elsif prefijo.empty? && !year.empty?
+    # Per-year totals
+    result_set = db.query("
+        SELECT nombre, contador::integer
+        FROM nombres
+        WHERE
+          anio = $1
+        ORDER BY contador DESC
+        LIMIT 50", year)
+  elsif !prefijo.empty? && year.empty?
+    # Filter only by prefix
+    result_set = db.query("
+        SELECT nombre, total::integer
+        FROM totales
+        WHERE
+            nombre LIKE $1
+        ORDER BY total DESC
+        LIMIT 50", prefijo + "%")
+  elsif !prefijo.empty? && !year.empty?
+    # We have both
+    result_set = db.query("
+        SELECT nombre, contador::integer
+        FROM nombres
+        WHERE
+            anio = $1 AND
+            nombre LIKE $2
+        ORDER BY contador DESC
+        LIMIT 50", year, prefijo + "%")
+  end
+
+  if !result_set.nil?
+    result_set.each do
+      nombre = result_set.read(String)
+      valor = result_set.read(Int32)
+      datos.push({nombre, valor})
+    end
+    result_set.close
+  end
+
+  if datos.empty?
+    raise "No data found"
+  end
+  # In this context, remove all composite names
+  datos.reject! { |row|
+    row[0].to_s.includes? " "
+  }
+  datos.insert(0, {"Nombre", "Cuantos?"})
+
+  if genero
+    datos.reject! { |row|
+      # How feminine is this name?
+      # Yes this database is upper case
+      puts "Checking #{row[1]} #{row[0]}"
+      feminidad = 0
+      sql = %(
+            SELECT COALESCE((SELECT frecuencia FROM mujeres WHERE nombre='#{row[0]?.to_s.upcase}'), 0) AS mujeres,
+                   COALESCE((SELECT frecuencia FROM hombres WHERE nombre='#{row[0]?.to_s.upcase}'), 0) AS hombres
+          )
+      puts "SQL: #{sql}"
+      db.query sql do |result_set|
+        result_set.each do
+          mujeres = result_set.read(Int32)
+          hombres = result_set.read(Int32)
+          puts "frecuencias: #{mujeres} #{hombres}"
+          if hombres == mujeres == 0
+            feminidad = 0.5
+          else
+            feminidad = mujeres / (hombres + mujeres)
+          end
+        end
+      end
+      # El overlap en 0.5 es intencional!
+      if (feminidad >= 0.5 && genero == "f") ||
+         (feminidad <= 0.5 && genero == "m")
+        false
+      else
+        true
+      end
+    }
+    puts "Data split by gender"
+  end
+  datos = datos[..10].map { |row|
+    [row[0].capitalize, row[1]]
+  }
+
+  if datos.size > 2
+    title = "¿Puede ser ... #{datos[1][0].to_s.titleize}? ¿O capaz que #{datos[2][0].to_s.titleize}? ¡Contame más!"
+  elsif datos.size == 2
+    title = "Me parece que ... #{datos[1][0].to_s.titleize}!"
+  else
+    title = "No tengo idea!"
+  end
+  {
+    "title" => title,
+    "data"  => datos,
+  }.to_json
+ensure
+  db.try &.close
+end
+
+get "/ping/" do
+  db = DB.open DBURL
+  db.exec("SELECT 42")
+  "OK"
+ensure
+  db.try &.close
+end

busqueda/funko.yml

@@ -0,0 +1,11 @@
+name: busqueda
+runtime: kemal
+options:
+  shard_build_options: "--release -d --error-trace"
+  ship_packages: []
+  devel_packages: []
+  healthcheck_options: "--interval=1m --timeout=2s --start-period=2s --retries=3"
+  healthcheck_command: "curl --fail http://localhost:3000/ping || exit 1"
+  copy_from_build:
+    - "public public"
+    - "bin/funko ."

busqueda/handler.py

@@ -1,164 +0,0 @@
-import unicodedata
-import urllib
-from collections import namedtuple as nt
-from dataclasses import dataclass
-from json import loads
-import logging
-
-import pygal
-import pyrqlite.dbapi2 as dbapi2
-import requests
-
-connection = dbapi2.connect(
-    host="10.61.0.1",
-    user="root",
-    port=4001,
-    password="",
-)
-
-
-def remove_accents(input_str):
-    nfkd_form = unicodedata.normalize("NFKD", input_str)
-    return "".join([c for c in nfkd_form if not unicodedata.combining(c)])
-
-
-def femininidad(nombre):
-    sql1 = """
-    SELECT COALESCE(frecuencia,0)
-    FROM mujeres WHERE nombre=:nombre
-    """
-    sql2 = """
-    SELECT COALESCE(frecuencia,0)
-    FROM hombres WHERE nombre=:nombre
-    """
-    with connection.cursor() as cursor:
-        nombre = nombre.strip().split()[0].strip().upper()
-        mujeres = cursor.execute(sql1, {"nombre": nombre}).fetchone()
-        mujeres = 0 if mujeres is None else mujeres[0]
-        hombres = cursor.execute(sql2, {"nombre": nombre}).fetchone()
-        hombres = 0 if hombres is None else hombres[0]
-        if hombres == mujeres == 0:
-            return 0.5
-        return mujeres / (hombres + mujeres)
-
-
-def split_por_genero(nombres):
-    femeninos = []
-    masculinos = []
-    for n in nombres:
-        fem = femininidad(n[1])
-        if fem is None:
-            femeninos.append(n)
-            masculinos.append(n)
-        elif fem >= 0.5:
-            femeninos.append(n)
-        else:
-            masculinos.append(n)
-    return {"f": femeninos, "m": masculinos}
-
-
-def handle(req):
-    """handle a request to the function
-    Args:
-        req (str): request body
-
-    {
-        p: prefijo del nombre,
-        g: genero del nombre,
-        a: año de nacimiento
-    }
-
-    """
-
-    try:
-        data = loads(req)
-    except Exception as e:
-        data = {}
-
-    try:
-        prefijo = data.get("p") or None
-        genero = data.get("g") or None
-        try:
-            año = int(data.get("a"))
-        except Exception:
-            año = None
-    except Exception as e:
-        prefijo = genero = año = None
-        return f"{req}  -- {e}", 400
-
-    if prefijo is not None:
-        prefijo = prefijo.strip().lower()
-
-    if genero not in ("f", "m"):
-        genero = None
-
-    if prefijo is None and año is None:  # Totales globales
-        with connection.cursor() as cursor:
-            sql = """
-                SELECT total, nombre
-                FROM totales
-                ORDER BY total DESC
-                LIMIT 50
-                """
-            cursor.execute(sql)
-            datos = [(r["total"], r["nombre"]) for r in cursor.fetchall()]
-
-    elif prefijo is None and año is not None:  # Totales por año
-        with connection.cursor() as cursor:
-            sql = """
-                SELECT contador, nombre
-                FROM nombres
-                WHERE
-                    anio = :anio
-                ORDER BY contador DESC
-                LIMIT 50
-                """
-            cursor.execute(sql, {"anio": año})
-            datos = [(r["contador"], r["nombre"]) for r in cursor.fetchall()]
-
-    elif prefijo is not None and año is None:
-        with connection.cursor() as cursor:
-            sql = """
-                SELECT total, nombre
-                FROM totales
-                WHERE
-                    nombre LIKE :nombre
-                ORDER BY total DESC
-                LIMIT 50
-                """
-            cursor.execute(sql, {"nombre": f"{prefijo}%"})
-            datos = [(r["total"], r["nombre"]) for r in cursor.fetchall()]
-    else:
-        with connection.cursor() as cursor:
-            sql = """
-                SELECT contador, nombre
-                FROM nombres
-                WHERE
-                    anio = :anio AND
-                    nombre LIKE :nombre
-                ORDER BY contador DESC
-                LIMIT 50
-                """
-            cursor.execute(sql, {"anio": año, "nombre": f"{prefijo}%"})
-            datos = [(r["contador"], r["nombre"]) for r in cursor.fetchall()]
-
-    if genero:
-        datos = split_por_genero(datos)[genero]
-
-    datos = datos[:10]
-
-    chart = pygal.HorizontalBar(height=400, show_legend=False, show_y_labels=True)
-    chart.x_labels = [nombre.title() for _, nombre in datos[::-1]]
-    if len(datos) > 1:
-        chart.title = f"¿Puede ser ... {datos[0][1].title()}? ¿O capaz que {datos[1][1].title()}? ¡Contáme más!"
-    elif len(datos) == 1:
-        chart.title = f"¡Hola {datos[0][1].title()}!"
-    elif len(datos) < 1:
-        chart.title = "¡No esssistís!"
-    chart.add("", [contador for contador, _ in datos[::-1]])
-
-    return (
-        chart.render(is_unicode=True),
-        200,
-        {"Content-Type": "image/svg+xml"},
-    )

busqueda/public/index.html

@@ -0,0 +1,243 @@
+<!DOCTYPE html>
+<html lang="en" data-theme="dark">
+  <head>
+    <meta charset="utf-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1" />
+    <script
+      type="text/javascript"
+      src="https://www.gstatic.com/charts/loader.js"
+    ></script>
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <!-- Font -->
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <link
+      href="https://fonts.googleapis.com/css2?family=Quicksand:wght@300..700&display=swap"
+      rel="stylesheet"
+    />
+    <link
+      rel="stylesheet"
+      href="https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.min.css"
+    />
+    <link
+      rel="stylesheet"
+      href="https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.colors.min.css"
+    />
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <link
+      href="https://fonts.googleapis.com/css2?family=Kode+Mono&display=swap"
+      rel="stylesheet"
+    />
+    <script type="text/javascript">
+      google.charts.load("current", { packages: ["corechart"] });
+      google.charts.setOnLoadCallback(drawChart);
+
+      async function drawChart() {
+        fetch("/", {
+          method: "POST",
+          headers: {
+            "Content-Type": "application/json",
+          },
+          body: JSON.stringify({
+            p: document.getElementById("p").value,
+            g: document.getElementById("g").value,
+            a: document.getElementById("a").value,
+          }),
+        })
+          .then((response) => response.json())
+          .then((json) => {
+            title = json["title"];
+            data = json["data"];
+            console.log(data);
+            data = google.visualization.arrayToDataTable(data);
+            var options = {
+              title: title,
+              titleTextStyle: {
+                color: "#aaa",
+              },
+              animation: {
+                startup: true,
+                duration: 1000,
+                easing: "out",
+              },
+              backgroundColor: "#1c212c",
+              vAxis: {
+                minValue: 0,
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              hAxis: {
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              legend: { position: 'none'},
+            };
+
+            var chart = new google.visualization.BarChart(
+              document.getElementById("chart")
+            );
+
+            chart.draw(data, options);
+          });
+      }
+    </script>
+    <style>
+      html * {
+        font-family: "Quicksand", sans-serif;
+      }
+    </style>
+  </head>
+  <body>
+    <main class="container" style="text-align: center">
+      <header>
+        <h1>Adivinar nombres por edad y género</h1>
+      </header>
+      <div id="chart" style="width: 80vw; height: 50vh; margin: auto"></div>
+      <form
+        onSubmit="return false;"
+        style="margin: auto; margin-top: 2em; width: 80%"
+      >
+      <fieldset class="grid">
+        <input type="text" name="p" id="p" placeholder="Como empieza tu nombre?" />
+        <select name="a" id="a">
+          <option selected value="">Año?</option>                  
+          <option value="1922">1922</option>
+          <option value="1923">1923</option>
+          <option value="1924">1924</option>
+          <option value="1925">1925</option>
+          <option value="1926">1926</option>
+          <option value="1927">1927</option>
+          <option value="1928">1928</option>
+          <option value="1929">1929</option>
+          <option value="1930">1930</option>
+          <option value="1931">1931</option>
+          <option value="1932">1932</option>
+          <option value="1933">1933</option>
+          <option value="1934">1934</option>
+          <option value="1935">1935</option>
+          <option value="1936">1936</option>
+          <option value="1937">1937</option>
+          <option value="1938">1938</option>
+          <option value="1939">1939</option>
+          <option value="1940">1940</option>
+          <option value="1941">1941</option>
+          <option value="1942">1942</option>
+          <option value="1943">1943</option>
+          <option value="1944">1944</option>
+          <option value="1945">1945</option>
+          <option value="1946">1946</option>
+          <option value="1947">1947</option>
+          <option value="1948">1948</option>
+          <option value="1949">1949</option>
+          <option value="1950">1950</option>
+          <option value="1951">1951</option>
+          <option value="1952">1952</option>
+          <option value="1953">1953</option>
+          <option value="1954">1954</option>
+          <option value="1955">1955</option>
+          <option value="1956">1956</option>
+          <option value="1957">1957</option>
+          <option value="1958">1958</option>
+          <option value="1959">1959</option>
+          <option value="1960">1960</option>
+          <option value="1961">1961</option>
+          <option value="1962">1962</option>
+          <option value="1963">1963</option>
+          <option value="1964">1964</option>
+          <option value="1965">1965</option>        
+          <option value="1966">1966</option>
+          <option value="1967">1967</option>
+          <option value="1968">1968</option>
+          <option value="1969">1969</option>
+          <option value="1970">1970</option>
+          <option value="1971">1971</option>
+          <option value="1972">1972</option>
+          <option value="1973">1973</option>
+          <option value="1974">1974</option>
+          <option value="1975">1975</option>
+          <option value="1976">1976</option>
+          <option value="1977">1977</option>
+          <option value="1978">1978</option>
+          <option value="1979">1979</option>
+          <option value="1980">1980</option>
+          <option value="1981">1981</option>
+          <option value="1982">1982</option>
+          <option value="1983">1983</option>
+          <option value="1984">1984</option>
+          <option value="1985">1985</option>
+          <option value="1986">1986</option>
+          <option value="1987">1987</option>
+          <option value="1988">1988</option>
+          <option value="1989">1989</option>
+          <option value="1990">1990</option>
+          <option value="1991">1991</option>
+          <option value="1992">1992</option>
+          <option value="1993">1993</option>
+          <option value="1994">1994</option>
+          <option value="1995">1995</option>
+          <option value="1996">1996</option>
+          <option value="1997">1997</option>
+          <option value="1998">1998</option>
+          <option value="1999">1999</option>
+          <option value="2000">2000</option>
+          <option value="2001">2001</option>
+          <option value="2002">2002</option>
+          <option value="2003">2003</option>
+          <option value="2004">2004</option>
+          <option value="2005">2005</option>
+          <option value="1966">1966</option>
+          <option value="1967">1967</option>
+          <option value="1968">1968</option>
+          <option value="1969">1969</option>
+          <option value="1970">1970</option>
+          <option value="1971">1971</option>
+          <option value="1972">1972</option>
+          <option value="1973">1973</option>
+          <option value="1974">1974</option>
+          <option value="1975">1975</option>
+          <option value="1976">1976</option>
+          <option value="1977">1977</option>
+          <option value="1978">1978</option>
+          <option value="1979">1979</option>
+          <option value="1980">1980</option>
+          <option value="1981">1981</option>
+          <option value="1982">1982</option>
+          <option value="1983">1983</option>
+          <option value="1984">1984</option>
+          <option value="1985">1985</option>
+          <option value="1986">1986</option>
+          <option value="1987">1987</option>
+          <option value="1988">1988</option>
+          <option value="1989">1989</option>
+          <option value="1990">1990</option>
+          <option value="1991">1991</option>
+          <option value="1992">1992</option>
+          <option value="1993">1993</option>
+          <option value="1994">1994</option>
+          <option value="1995">1995</option>
+          <option value="1996">1996</option>
+          <option value="1997">1997</option>
+          <option value="1998">1998</option>
+          <option value="1999">1999</option>
+          <option value="2000">2000</option>
+          <option value="2001">2001</option>
+          <option value="2002">2002</option>
+          <option value="2003">2003</option>
+          <option value="2004">2004</option>
+          <option value="2005">2005</option>
+        </select>
+        <select name="g" id="g" />
+          <option selected value="">Género?</option>                  
+          <option value="f">Femenino</option>
+          <option value="m">Masculino</option>  
+        </select>
+        <input type="submit" value="Buscar" onCLick="drawChart();" />
+      </fieldset>
+      </form>
+    </main>
+  </body>
+</html>

busqueda/requirements.txt

@@ -1,3 +0,0 @@
-pygal
-requests
-pyrqlite

busqueda/shard.yml

@@ -0,0 +1,18 @@
+name: busqueda
+version: 0.1.0
+
+targets:
+  funko:
+    main: main.cr
+
+dependencies:
+  kemal:
+    github: kemalcr/kemal
+  pg:
+    github: will/crystal-pg
+  pool:
+    github: ysbaddaden/pool
+
+# development_dependencies:
+#   webmock:
+#     github: manastech/webmock.cr

c-historico/handler.cr

@@ -1,109 +0,0 @@
-require "http/client"
-require "http/headers"
-require "http/request"
-require "ishi/html"
-require "json"
-require "uuid"
-
-class Handler
-  def format_buffer(buffer, canvas_name)
-    # Process the gnuplot output so it works in the page
-    #
-    # buffer is the Ishi output
-    # name is a string to replace for gnuplot_canvas so
-    # we can have multiple charts in a page
-
-    html = buffer.to_s.split("\n")
-    html = html[html.index("<script type=\"text/javascript\">")..html.index("</script>")]
-    html = html.join("\n") + %(
-    <div class="gnuplot">
-    <canvas id="Tile" width="32" height="32" hidden></canvas>
-    <table class="plot">
-    <tr><td>
-    <canvas id="gnuplot_canvas" width="800" height="300" tabindex="0">
-    Sorry, your browser seems not to support the HTML 5 canvas element
-    </canvas>
-    </td></tr>
-    </table>
-    <script type="text/javascript" defer>
-    gnuplot.init(); gnuplot_canvas();
-    </script>
-    </div>
-    )
-    # This ID needs to be unique in case 
-    # we have 2 charts in the same page
-    html.gsub("gnuplot_canvas", canvas_name)
-  end
-
-  def query(sql)
-    params = URI::Params.encode({"q": sql})
-    response = HTTP::Client.get URI.new(
-      "http",
-      "10.61.0.1",
-      4001,
-      "/db/query",
-      params)
-
-    # This API only has a values key when there are actual results
-    results = JSON.parse(response.body)["results"][0].as_h
-    if results.has_key?("values")
-      return results["values"].as_a.map { |r|
-        [r[0].as_i, r[1].as_i]
-      }
-    end
-    # Return a dummy result
-    [[1922, 0]]
-  end
-
-  nombres = [] of String
-
-  def normalize_name(s)
-    # Remove diacritics, turn lowercase
-    normalized = s.unicode_normalize(:nfkd).chars
-    normalized.reject! { |c|
-      !c.ascii_letter?
-    }.join("").downcase
-  end
-
-  def run(request : HTTP::Request)
-    unless (body = request.body).nil?
-      query = JSON.parse(body)
-      nombres = query["i"].as_s.split(",").map { |n| n.strip }
-      nombres.reject! { |n| n.size == 0 }
-    end
-
-    if nombres.nil? || nombres.empty?
-      nombres = ["maria", "juan"]
-    end
-
-    # Remove all diacritics and whatnot
-    nombres = nombres.map { |n|
-      normalize_name n
-    }
-
-    puts "Processing #{nombres}"
-
-    buffer = IO::Memory.new
-    Ishi.new(buffer) do
-      canvas_size(800, 300)
-      show_key(true)
-      xrange(1922..2015)
-      nombres.map { |nombre|
-        sql = "SELECT anio, contador FROM nombres WHERE nombre = '#{nombre}' ORDER BY anio"
-        x = Array(Int32).new
-        y = Array(Int32).new
-        query(sql).map { |r|
-          x << r[0]
-          y << r[1]
-        }
-        plot(x, y, title: nombre.titleize, style: :lines, linewidth: 3)
-      }
-    end
-
-    {
-      body:        format_buffer(buffer, "historico"),
-      status_code: 200,
-      headers:     HTTP::Headers{"Content-Type" => "text/html"},
-    }
-  end
-end

deploy.sh

@@ -1,5 +1,31 @@
 #!/bin/sh -x
 set -e
+export OPENFAAS_URL=http://pinky:8082
+#pass faas.ralsina.me | faas-cli login -u admin --password-stdin
 
-pass faas.ralsina.me | faas-cli login --password-stdin
+#pass iol-pass | faas-cli secret create iol-pass
-faas-cli deploy -f functions.yml
+#pass iol-user | faas-cli secret create iol-user
+#pass iol-api-secret | faas-cli secret create iol-api-secret
+#pass nombres-user | faas-cli secret create nombres-user
+#pass nombres-pass | faas-cli secret create nombres-pass
+#faas-cli deploy -f functions.yml $*
+
+export FAASO_SERVER=http://rocky:8888/admin
+pass faaso-rocky | faaso login
+pass nombres-user | faaso secret -a historico user
+pass nombres-pass | faaso secret -a historico pass
+echo "rocky.tail20c16.ts.net"      | faaso secret -a historico dbhost 
+faaso build busqueda
+faaso scale busqueda 0
+faaso scale busqueda 1
+pass nombres-user | faaso secret -a busqueda user
+pass nombres-pass | faaso secret -a busqueda pass
+echo "rocky.tail20c16.ts.net"      | faaso secret -a busqueda dbhost 
+faaso build historico
+faaso scale historico 0
+faaso scale historico 1
+rsync -rav nombres.ralsina.me/* ralsina@rocky:/data/stacks/web/websites/nombres.ralsina.me/
+
+faaso build tapas
+faaso scale tapas 0
+faaso scale tapas 1

functions.yml

@@ -1,23 +0,0 @@
-version: 1.0
-provider:
-  name: openfaas
-  gateway: http://pinky:8082
-functions:
-  busqueda:
-    lang: python3-flask
-    handler: ./busqueda
-    image: ralsina/nombres_busqueda:latest
-  historico:
-    lang: python3-flask
-    handler: ./historico
-    image: ralsina/nombres_historico:latest
-  tapas:
-    lang: python3-flask
-    handler: ./tapas
-    image: ralsina/tapas:latest
-  c-historico:
-    lang: crystal-http
-    handler: ./c-historico
-    image: ralsina/c-historico:latest
-    build_args:
-      ADDITIONAL_PACKAGE: gnuplot

historico/README.md

@@ -0,0 +1,11 @@
+# Readme for Historico
+
+This is a funko using the Crystal runtime for [FaaSO](https://git.ralsina.me/ralsina/faaso)
+
+## What is Historico
+
+Write here what it is
+
+## How to use Historico
+
+And so on.

historico/funko.cr

@@ -0,0 +1,61 @@
+require "json"
+require "kemal"
+require "pg"
+require "pool/connection"
+
+# get credentials from secrets
+USER   = File.read("/secrets/user").strip
+PASS   = File.read("/secrets/pass").strip
+DBHOST = File.read("/secrets/dbhost").strip
+
+DBURL = "postgres://#{USER}:#{PASS}@#{DBHOST}:5432/nombres"
+puts "Connnecting to #{DBURL}"
+
+# Connect to the database and get information about
+# the requested names
+get "/" do |env|
+  # Names are query parameters
+  # Split by commas, capitalize and take the first 5
+  names = env.params.query["names"]
+    .split(",").map(&.strip.capitalize)[..4]
+
+  # Prepare results table
+  results = [] of Array(String)
+  results << ["Año"] + names
+  (1922..2015).each do |anio|
+    results << [anio.to_s]
+  end
+  # Connect using credentials provided
+  db = DB.open DBURL
+    # Get the information for each name
+    names.map do |name|
+      # Normalize: remove diacritics etc.
+      name = name.unicode_normalize(:nfkd)
+        .chars.reject! { |character|
+        !character.ascii_letter? && (character != ' ')
+      }.join("").downcase
+
+      counter_per_year = {} of Int32 => Int32
+      db.query("
+      SELECT anio::integer, contador::integer
+        FROM nombres WHERE nombre = $1", name) do |result_set|
+        result_set.each do
+          counter_per_year[result_set.read(Int32)] = result_set.read(Int32)
+        end
+      end
+      (1922..2015).each do |anio|
+        results[anio - 1921] << counter_per_year.fetch(anio, 0).to_s
+      end
+    end
+  results.to_json
+ensure
+  db.try &.close
+end
+
+get "/ping/" do
+  db = DB.open DBURL
+  db.exec("SELECT 42")
+  "OK"
+ensure
+  db.try &.close
+end

historico/funko.yml

@@ -0,0 +1,11 @@
+name: historico
+runtime: kemal
+options:
+  shard_build_options: "--release -d --error-trace"
+  ship_packages: []
+  devel_packages: []
+  healthcheck_options: "--interval=1m --timeout=2s --start-period=2s --retries=3"
+  healthcheck_command: "curl --fail http://localhost:3000/ping || exit 1"
+  copy_from_build:
+    - "public public"
+    - "bin/funko ."

historico/handler.py

@@ -1,66 +0,0 @@
-import unicodedata
-import urllib
-from collections import defaultdict as ddict
-from dataclasses import dataclass
-from json import loads
-
-import pygal
-import pyrqlite.dbapi2 as dbapi2
-import requests
-
-connection = dbapi2.connect(
-    host="10.61.0.1",
-    user="root",
-    port=4001,
-    password="",
-)
-
-
-def remove_accents(input_str):
-    nfkd_form = unicodedata.normalize("NFKD", input_str)
-    return "".join([c for c in nfkd_form if not unicodedata.combining(c)])
-
-
-def handle(req):
-    """handle a request to the function
-    Args:
-        req (str): request body
-
-    {"i": ["nombre1, nombre2"]}
-
-    """
-    nombres = []
-    try:
-        nombres = loads(req)
-        nombres = nombres["i"].split(",")
-        nombres = [remove_accents(x.strip().lower()) for x in nombres]
-        nombres = [n for n in nombres if n]
-    except Exception:
-        pass
-
-    if not nombres:
-        nombres = ["maria", "juan"]
-
-    chart = pygal.Line(
-        height=200, fill=True, human_readable=True, show_minor_x_labels=False
-    )
-    chart.x_labels = [str(x) for x in range(1922, 2015)]
-    chart.x_labels_major = [str(x) if x % 10 == 0 else "" for x in range(1922, 2015)]
-    for nombre in nombres:
-        datos = ddict(int)
-        with connection.cursor() as cursor:
-            sql = """
-                SELECT anio, contador, nombre
-                FROM nombres
-                WHERE nombre = :nombre
-                ORDER BY anio
-                """
-            cursor.execute(sql, {"nombre": nombre})
-            datos.update({r["anio"]: r["contador"] for r in cursor.fetchall()})
-            chart.add(nombre.title(), [datos[x] for x in range(1922, 2015)])
-
-    chart.x_labels = [str(n) for n in range(1922, 2015)]
-    chart.x_labels_major = [str(n) for n in range(1920, 2020, 10)]
-
-    # return Response(chart.render(is_unicode=True), mimetype="image/svg+xml")
-    return chart.render(is_unicode=True), 200, {"Content-Type": "image/svg+xml"}

historico/public/index.html

@@ -0,0 +1,109 @@
+<!DOCTYPE html>
+<html lang="en" data-theme="dark">
+  <head>
+    <meta charset="utf-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1" />
+    <script
+      type="text/javascript"
+      src="https://www.gstatic.com/charts/loader.js"
+    ></script>
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <!-- Font -->
+    <link rel="preconnect" href="https://fonts.googleapis.com">
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin>
+    <link href="https://fonts.googleapis.com/css2?family=Quicksand:wght@300..700&display=swap"
+    rel="stylesheet">
+    <link
+      rel="stylesheet"
+      href="https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.min.css"
+    />
+    <link
+      rel="stylesheet"
+      href="https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.colors.min.css"
+    />
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <link
+      href="https://fonts.googleapis.com/css2?family=Kode+Mono&display=swap"
+      rel="stylesheet"
+    />
+    <script type="text/javascript">
+      google.charts.load("current", { packages: ["corechart"] });
+      google.charts.setOnLoadCallback(drawChart);
+
+      async function drawChart() {
+        fetch(
+          "/faaso/historico/?" +
+            new URLSearchParams({
+              names: document.getElementById("nombres").value,
+            })
+        )
+          .then((response) => response.json())
+          .then((json) => {
+            var data = [json[0]];
+            data.push(
+              ...json
+                .slice(1)
+                .map((item) => item.map((value) => parseInt(value)))
+            );
+            data = google.visualization.arrayToDataTable(data);
+            var options = {
+              title: "",
+              animation: {
+                startup: true,
+                duration: 1000,
+                easing: "out",
+              },
+              backgroundColor: "#1c212c",
+              vAxis: {
+                minValue: 0,
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              hAxis: {
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              legend: { position: "bottom", textStyle: { color: "#aaa" } },
+            };
+
+            var chart = new google.visualization.LineChart(
+              document.getElementById("chart")
+            );
+
+            chart.draw(data, options);
+          });
+      }
+    </script>
+  <style>
+    html * {
+      font-family: 'Quicksand', sans-serif;
+    }
+  </style>
+  </head>
+  <body>
+    <main class="container" style="text-align: center">
+      <header>
+        <h1>Popularidad de Nombres en Argentina</h1>
+      </header>
+      <div id="chart" style="width: 80vw; height: 50vh; margin: auto"></div>
+      <form
+        role="search"
+        onSubmit="return false;"
+        style="margin: auto; margin-top: 2em; width: 80%"
+      >
+        <input
+          type="search"
+          name="nombres"
+          id="nombres"
+          placeholder="Nombres separados con comas"
+          aria-label="Search"
+        />
+        <input type="submit" value="Buscar" onCLick="drawChart();" />
+      </form>
+    </main>
+  </body>
+</html>

historico/requirements.txt

@@ -1,3 +0,0 @@
-pygal
-requests
-pyrqlite

historico/shard.yml

@@ -0,0 +1,14 @@
+name: historico
+version: 0.1.0
+
+targets:
+  funko:
+    main: main.cr
+
+dependencies:
+  kemal:
+    github: kemalcr/kemal
+  pg:
+    github: will/crystal-pg
+  pool:
+    github: ysbaddaden/pool

iol/handler.py

@@ -0,0 +1,157 @@
+import logging
+import time
+from functools import lru_cache
+
+import requests as r
+from fastapi import APIRouter
+
+BASE_URL = "https://api.invertironline.com/"
+USER = open("/var/openfaas/secrets/iol-user").read().strip()
+PASS = open("/var/openfaas/secrets/iol-pass").read().strip()
+SECRET = open("/var/openfaas/secrets/iol-api-secret").read().strip()
+
+router = APIRouter()
+
+last_results = {}
+
+
+def get_ttl_hash(seconds=3600):
+    """Return the same value withing `seconds` time period"""
+    return round(time.time() / seconds)
+
+
+@lru_cache
+def get_token(ttl_hash=None):
+    logging.error("getting token")
+    url = BASE_URL + "token"
+    data = {"username": USER, "password": PASS, "grant_type": "password"}
+    response = r.post(url, data=data)
+    access_token = response.json()["access_token"]
+    refresh_token = response.json()["refresh_token"]
+    return access_token, refresh_token
+
+
+def refresh_token(refresh_token):
+    url = BASE_URL + "token"
+    data = {"refresh_token": refresh_token, "grant_type": "refresh_token"}
+    response = r.post(url, data=data)
+    access_token = response.json()["access_token"]
+    refresh_token = response.json()["refresh_token"]
+    return access_token, refresh_token
+
+
+paises = {
+    "US": "estados_Unidos",
+    "AR": "argentina",
+}
+
+
+@lru_cache
+def get(url, ttl_hash=None):
+    logging.error("getting data")
+    access, refresh = get_token(ttl_hash=get_ttl_hash())
+    response = r.get(
+        url, headers={"Authorization": "Bearer " + access, "Accept": "application/json"}
+    )
+    return response.json()
+
+
+@router.get("/{secret}/accion/{pais}/{accion}")
+def get_accion(secret, pais, accion):
+    if secret != SECRET:
+        raise Exception("BAD")
+    pais = pais.upper()
+    accion = accion.upper()
+    try:
+        access, refresh = get_token(ttl_hash=get_ttl_hash())
+        url = (
+            BASE_URL
+            + f"/api/v2/Cotizaciones/acciones/{pais}/Todos?cotizacionInstrumentoModel.instrumento=acciones&cotizacionInstrumentoModel.pais={paises[pais]}&api_key={access}"
+        )
+        data = get(url, ttl_hash=get_ttl_hash())
+        last_results[f"accion/{pais}/{accion}"] = [
+            a for a in data["titulos"] if a["simbolo"] == accion
+        ][0]
+    except:
+        pass
+    return last_results[f"accion/{pais}/{accion}"]
+
+
+@router.get("/{secret}/bono/{nombre}")
+def get_bono(secret, nombre):
+    if secret != SECRET:
+        raise Exception("BAD")
+    nombre = nombre.upper()
+    access, refresh = get_token(ttl_hash=get_ttl_hash())
+    try:
+        url = (
+            BASE_URL
+            + f"/api/v2/Cotizaciones/titulosPublicos/ar/Todos?cotizacionInstrumentoModel.instrumento=titulosPublicos&cotizacionInstrumentoModel.pais=argentina&api_key={access}"
+        )
+        data = get(url, ttl_hash=get_ttl_hash())
+        last_results[f"bono/{nombre}"] = [
+            a for a in data["titulos"] if a["simbolo"] == nombre
+        ][0]
+    except:
+        pass
+    return last_results[f"bono/{nombre}"]
+
+
+@router.get("/{secret}/cedear/{nombre}")
+def get_cedear(secret, nombre):
+    if secret != SECRET:
+        raise Exception("BAD")
+    nombre = nombre.upper()
+    access, refresh = get_token(ttl_hash=get_ttl_hash())
+    try:
+        url = (
+            BASE_URL
+            + f"/api/v2/Cotizaciones/cedears/ar/Todos?cotizacionInstrumentoModel.instrumento=cedears&cotizacionInstrumentoModel.pais=argentina&api_key={access}"
+        )
+        data = get(url, ttl_hash=get_ttl_hash())
+        last_results[f"cedear/{nombre}"] = [
+            a for a in data["titulos"] if a["simbolo"] == nombre
+        ][0]
+    except:
+        pass
+    return last_results[f"cedear/{nombre}"]
+
+
+@router.get("/{secret}/ON/{nombre}")
+def get_on(secret, nombre):
+    if secret != SECRET:
+        raise Exception("BAD")
+    nombre = nombre.upper()
+    access, refresh = get_token(ttl_hash=get_ttl_hash())
+    try:
+        url = (
+            BASE_URL
+            + f"/api/v2/Cotizaciones/obligacionesnegociables/ar/Todos?cotizacionInstrumentoModel.instrumento=obligacionesNegociables&cotizacionInstrumentoModel.pais=argentina&api_key={access}"
+        )
+        data = get(url, ttl_hash=get_ttl_hash())
+        last_results[f"ON/{nombre}"] = [
+            a for a in data["titulos"] if a["simbolo"] == nombre
+        ][0]
+    except:
+        pass
+    return last_results[f"ON/{nombre}"]
+
+
+@router.get("/{secret}/ADR/{nombre}")
+def get_adrs(secret, nombre):
+    if secret != SECRET:
+        raise Exception("BAD")
+    nombre = nombre.upper()
+    access, refresh = get_token(ttl_hash=get_ttl_hash())
+    try:
+        url = (
+            BASE_URL
+            + f"/api/v2/Cotizaciones/adrs/us/Todos?cotizacionInstrumentoModel.instrumento=aDRs&cotizacionInstrumentoModel.pais=estados_Unidos&api_key={access}"
+        )
+        data = get(url, ttl_hash=get_ttl_hash())
+        last_results[f"ADR/{nombre}"] = [
+            a for a in data["titulos"] if a["simbolo"] == nombre
+        ][0]
+    except:
+        pass
+    return last_results[f"ADR/{nombre}"]

iol/requirements.txt

@@ -0,0 +1,3 @@
+fastapi
+requests
+uvicorn[standard]

nombres.ralsina.me/index.html

@@ -0,0 +1,340 @@
+<!DOCTYPE html>
+<html lang="en" data-theme="dark">
+  <head>
+    <meta charset="utf-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1" />
+    <script
+      type="text/javascript"
+      src="https://www.gstatic.com/charts/loader.js"
+    ></script>
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <!-- Font -->
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <link
+      href="https://fonts.googleapis.com/css2?family=Quicksand:wght@300..700&display=swap"
+      rel="stylesheet"
+    />
+    <link
+      rel="stylesheet"
+      href="https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.min.css"
+    />
+    <link
+      rel="stylesheet"
+      href="https://cdn.jsdelivr.net/npm/@picocss/pico@2/css/pico.colors.min.css"
+    />
+    <link rel="preconnect" href="https://fonts.googleapis.com" />
+    <link rel="preconnect" href="https://fonts.gstatic.com" crossorigin />
+    <link
+      href="https://fonts.googleapis.com/css2?family=Kode+Mono&display=swap"
+      rel="stylesheet"
+    />
+    <script type="text/javascript">
+      google.charts.load("current", { packages: ["corechart"] });
+      google.charts.setOnLoadCallback(drawChart);
+
+      async function drawChart() {
+        drawChart1();
+        drawChart2();
+      }
+
+      async function drawChart1() {
+        fetch("https://faaso-prod.ralsina.me/faaso/busqueda/", {
+          method: "POST",
+          headers: {
+            "Content-Type": "application/json",
+          },
+          body: JSON.stringify({
+            p: document.getElementById("p").value,
+            g: document.getElementById("g").value,
+            a: document.getElementById("a").value,
+          }),
+        })
+          .then((response) => response.json())
+          .then((json) => {
+            title = json["title"];
+            data = json["data"];
+            console.log(data);
+            data = google.visualization.arrayToDataTable(data);
+            var options = {
+              title: title,
+              titleTextStyle: {
+                color: "#aaa",
+              },
+              animation: {
+                startup: true,
+                duration: 1000,
+                easing: "out",
+              },
+              backgroundColor: "#1c212c",
+              vAxis: {
+                minValue: 0,
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              hAxis: {
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              legend: { position: 'none'},
+            };
+
+            var chart1 = new google.visualization.BarChart(
+              document.getElementById("chart1")
+            );
+
+            chart1.draw(data, options);
+          });
+      }
+      async function drawChart2() {
+        fetch(
+          "https://faaso-prod.ralsina.me/faaso/historico/?" +
+            new URLSearchParams({
+              names: document.getElementById("nombres").value,
+            })
+        )
+          .then((response) => response.json())
+          .then((json) => {
+            var data = [json[0]];
+            data.push(
+              ...json
+                .slice(1)
+                .map((item) => item.map((value) => parseInt(value)))
+            );
+            data = google.visualization.arrayToDataTable(data);
+            var options = {
+              title: "",
+              animation: {
+                startup: true,
+                duration: 1000,
+                easing: "out",
+              },
+              backgroundColor: "#1c212c",
+              vAxis: {
+                minValue: 0,
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              hAxis: {
+                gridlines: { color: "#666" },
+                minorGridlines: { color: "#1c212c" },
+                textStyle: { color: "#aaa" }
+              },
+              legend: { position: "bottom", textStyle: { color: "#aaa" } },
+            };
+
+            var chart2 = new google.visualization.LineChart(
+              document.getElementById("chart2")
+            );
+
+            chart2.draw(data, options);
+          });
+      }
+    </script>
+    <style>
+      html * {
+        font-family: "Quicksand", sans-serif;
+      }
+    </style>
+  </head>
+  <body>
+    <main class="container" style="text-align: center">
+      <header>
+        <h1>Cosas con Datos de Nombres de Argentina</h1>
+        <h2>Adivinar nombres por edad y género</h2>
+      </header>
+      <div id="chart1" style="width: 80vw; height: 50vh; margin: auto"></div>
+      <form
+        onSubmit="return false;"
+        style="margin: auto; margin-top: 2em; width: 80%"
+      >
+      <fieldset class="grid">
+        <input type="text" name="p" id="p" placeholder="Como empieza tu nombre?" />
+        <select name="a" id="a">
+          <option selected value="">Año?</option>                  
+          <option value="1922">1922</option>
+          <option value="1923">1923</option>
+          <option value="1924">1924</option>
+          <option value="1925">1925</option>
+          <option value="1926">1926</option>
+          <option value="1927">1927</option>
+          <option value="1928">1928</option>
+          <option value="1929">1929</option>
+          <option value="1930">1930</option>
+          <option value="1931">1931</option>
+          <option value="1932">1932</option>
+          <option value="1933">1933</option>
+          <option value="1934">1934</option>
+          <option value="1935">1935</option>
+          <option value="1936">1936</option>
+          <option value="1937">1937</option>
+          <option value="1938">1938</option>
+          <option value="1939">1939</option>
+          <option value="1940">1940</option>
+          <option value="1941">1941</option>
+          <option value="1942">1942</option>
+          <option value="1943">1943</option>
+          <option value="1944">1944</option>
+          <option value="1945">1945</option>
+          <option value="1946">1946</option>
+          <option value="1947">1947</option>
+          <option value="1948">1948</option>
+          <option value="1949">1949</option>
+          <option value="1950">1950</option>
+          <option value="1951">1951</option>
+          <option value="1952">1952</option>
+          <option value="1953">1953</option>
+          <option value="1954">1954</option>
+          <option value="1955">1955</option>
+          <option value="1956">1956</option>
+          <option value="1957">1957</option>
+          <option value="1958">1958</option>
+          <option value="1959">1959</option>
+          <option value="1960">1960</option>
+          <option value="1961">1961</option>
+          <option value="1962">1962</option>
+          <option value="1963">1963</option>
+          <option value="1964">1964</option>
+          <option value="1965">1965</option>        
+          <option value="1966">1966</option>
+          <option value="1967">1967</option>
+          <option value="1968">1968</option>
+          <option value="1969">1969</option>
+          <option value="1970">1970</option>
+          <option value="1971">1971</option>
+          <option value="1972">1972</option>
+          <option value="1973">1973</option>
+          <option value="1974">1974</option>
+          <option value="1975">1975</option>
+          <option value="1976">1976</option>
+          <option value="1977">1977</option>
+          <option value="1978">1978</option>
+          <option value="1979">1979</option>
+          <option value="1980">1980</option>
+          <option value="1981">1981</option>
+          <option value="1982">1982</option>
+          <option value="1983">1983</option>
+          <option value="1984">1984</option>
+          <option value="1985">1985</option>
+          <option value="1986">1986</option>
+          <option value="1987">1987</option>
+          <option value="1988">1988</option>
+          <option value="1989">1989</option>
+          <option value="1990">1990</option>
+          <option value="1991">1991</option>
+          <option value="1992">1992</option>
+          <option value="1993">1993</option>
+          <option value="1994">1994</option>
+          <option value="1995">1995</option>
+          <option value="1996">1996</option>
+          <option value="1997">1997</option>
+          <option value="1998">1998</option>
+          <option value="1999">1999</option>
+          <option value="2000">2000</option>
+          <option value="2001">2001</option>
+          <option value="2002">2002</option>
+          <option value="2003">2003</option>
+          <option value="2004">2004</option>
+          <option value="2005">2005</option>
+          <option value="1966">1966</option>
+          <option value="1967">1967</option>
+          <option value="1968">1968</option>
+          <option value="1969">1969</option>
+          <option value="1970">1970</option>
+          <option value="1971">1971</option>
+          <option value="1972">1972</option>
+          <option value="1973">1973</option>
+          <option value="1974">1974</option>
+          <option value="1975">1975</option>
+          <option value="1976">1976</option>
+          <option value="1977">1977</option>
+          <option value="1978">1978</option>
+          <option value="1979">1979</option>
+          <option value="1980">1980</option>
+          <option value="1981">1981</option>
+          <option value="1982">1982</option>
+          <option value="1983">1983</option>
+          <option value="1984">1984</option>
+          <option value="1985">1985</option>
+          <option value="1986">1986</option>
+          <option value="1987">1987</option>
+          <option value="1988">1988</option>
+          <option value="1989">1989</option>
+          <option value="1990">1990</option>
+          <option value="1991">1991</option>
+          <option value="1992">1992</option>
+          <option value="1993">1993</option>
+          <option value="1994">1994</option>
+          <option value="1995">1995</option>
+          <option value="1996">1996</option>
+          <option value="1997">1997</option>
+          <option value="1998">1998</option>
+          <option value="1999">1999</option>
+          <option value="2000">2000</option>
+          <option value="2001">2001</option>
+          <option value="2002">2002</option>
+          <option value="2003">2003</option>
+          <option value="2004">2004</option>
+          <option value="2005">2005</option>
+        </select>
+        <select name="g" id="g" />
+          <option selected value="">Género?</option>                  
+          <option value="f">Femenino</option>
+          <option value="m">Masculino</option>  
+        </select>
+        <input type="submit" value="Buscar" onCLick="drawChart1();" />
+      </fieldset>
+      </form>
+    </main>
+    <main class="container" style="text-align: center">
+      <header>
+        <h2>Popularidad de Nombres en Argentina</h2>
+      </header>
+      <div id="chart2" style="width: 80vw; height: 50vh; margin: auto"></div>
+      <form
+        role="search"
+        onSubmit="return false;"
+        style="margin: auto; margin-top: 2em; width: 80%"
+      >
+        <input
+          type="search"
+          name="nombres"
+          id="nombres"
+          placeholder="Nombres separados con comas"
+          aria-label="Search"
+	        value="juan,maria"
+        />
+        <input type="submit" value="Buscar" onCLick="drawChart2();" />
+      </form>
+    </main>
+
+    <main class="container">
+      <header>
+        <h2>Cosas Nerds</h2>
+      </header>
+<ul>
+<li>Los datos utilizados son provistos por el RENAPER (Registro Nacional de las Personas), y sólo son útiles para Argentina: <a href="http://www.datos.gob.ar/dataset/otros-nombres-personas-fisicas">Los Datos</a>
+<li>Le saqué todos los acentos a la data. Después de todo, si te llamás María y te digo Maria no te vas a ofender.
+<li>Había una página del RENAPER que hacía algo parecido pero era una porquería. Ahora hay otra que ni miré.
+<li>La data no es perfecta. En el caso de algunos nombres muy peculiares están duplicados. Por ejemplo, mi cuñado se llama "Pedro Fuat", y hay dos registros en el mismo año. Sospecho que es un duplicado de él mismo. Nota de color: los tres hijos de mi suegra tienen nombres que nadie más tiene en la historia de la Argentina.
+<li>Los datos están publicados de manera conveniente <a href="https://www.dolthub.com/repositories/ralsina/nombres_argentina_1922_2005/doc/main">en dolthub.</a>
+<li>La detección de género está hecha en base a datos del INE de España (lista de los nombres de personas nacidas en España con más de 20 ocurrencias)
+<li>Si alguien tiene data similar de otros países me encantaría hacer páginas similares.
+<li>Si les interesa es muy fácil hacer un Jupyter Notebook para jugar con estos datos.
+<li>Código y cosas: https://github.com/ralsina/nombres
+</ul>
+La aplicación consiste de:
+<ul>
+<li>Una página estática (ésta!)
+<li>Los charts SVG están hechos con Google Charts
+<li>El código de backend está hecho en Crystal
+<li>Todo está ejecutándose en una computadora categoría RaspBerry Pi usando <a href="faaso.ralsina.me">faaso</a> con una base de datos Postgres
+</ul>
+    </main>
+
+  </body>
+</html>

old-busqueda/handler.cr

@@ -0,0 +1,228 @@
+require "http/client"
+require "http/headers"
+require "http/request"
+require "ishi/html"
+require "json"
+require "uuid"
+require "db"
+require "pg"
+
+USER   = File.read("/var/openfaas/secrets/nombres-user").strip
+PASS   = File.read("/var/openfaas/secrets/nombres-pass").strip
+DB_URL = "postgres://#{USER}:#{PASS}@10.61.0.1:5432/nombres"
+
+class Handler
+  # This class is the entry point for the OpenFaaS function.
+  # run() is the important bit
+
+  def format_buffer(buffer, canvas_name, title = "")
+    # Process the gnuplot output so it works in the page
+    #
+    # buffer is the Ishi output
+    # name is a string to replace for gnuplot_canvas so
+    #      we can have multiple charts in a page
+    # title is added on top of the chart
+
+    html = buffer.to_s.split("\n")
+    html = html[html.index("<script type=\"text/javascript\">")..html.index("</script>")]
+    html = "<b>#{title}</b>" + html.join("\n") + %(
+    <div class="gnuplot">
+    <canvas id="Tile" width="32" height="32" hidden></canvas>
+    <table class="plot">
+    <tr><td>
+    <canvas id="gnuplot_canvas" width="800" height="300" tabindex="0">
+    Sorry, your browser seems not to support the HTML 5 canvas element
+    </canvas>
+    </td></tr>
+    </table>
+    <script type="text/javascript" defer>
+    gnuplot.init(); gnuplot_canvas();
+    </script>
+    </div>
+    )
+    # This ID needs to be unique in case
+    # we have 2 charts in the same page
+    html.gsub("gnuplot_canvas", canvas_name)
+  end
+
+  def normalize_name(s)
+    # Remove diacritics, turn lowercase
+    normalized = s.unicode_normalize(:nfkd).chars
+    normalized.reject! { |character|
+      !character.ascii_letter?
+    }.join("").downcase
+  end
+
+  def run(request : HTTP::Request)
+    # Try to find most popular names based on a prefix, year and gender.
+    #
+    # Request body is JSON in this form:
+    #
+    # {
+    #     p: prefijo del nombre,
+    #     g: genero del nombre,
+    #     y: year de nacimiento
+    # }
+
+    if (body = request.body).nil?
+      query = {"p": "", "g": "", "a": ""}
+    else
+      query = Hash(String, String).from_json(body)
+    end
+
+    # Sanitize input.
+    # Each one either a valid string or nil
+    prefijo = query.fetch("p", "")
+    genero = query.fetch("g", "")
+    year = query.fetch("y", "")
+
+    if !prefijo.empty?
+      prefijo = normalize_name(prefijo)
+    else
+      prefijo = nil
+    end
+
+    if !["f", "m"].includes?(genero)
+      genero = nil
+    end
+
+    year = year.to_i?
+
+    datos = [] of Tuple(Int32, String)
+    DB.open(DB_URL) do |cursor|
+      if prefijo.nil? && year.nil?
+        # Global totals
+        result_set = cursor.query("
+          SELECT total::integer, nombre
+          FROM totales
+          ORDER BY total DESC
+          LIMIT 50")
+      elsif prefijo.nil? && !year.nil?
+        # Per-year totals
+        result_set = cursor.query("
+          SELECT contador::integer, nombre
+          FROM nombres
+          WHERE
+            anio = $1
+          ORDER BY contador DESC
+          LIMIT 50", year)
+      elsif !prefijo.nil? && year.nil?
+        # Filter only by prefix
+        result_set = cursor.query("
+          SELECT total::integer, nombre
+          FROM totales
+          WHERE
+              nombre LIKE $1
+          ORDER BY total DESC
+          LIMIT 50", prefijo + "%")
+      elsif !prefijo.nil? && !year.nil?
+        # We have both
+        result_set = cursor.query("
+          SELECT contador::integer, nombre
+          FROM nombres
+          WHERE
+              anio = $1 AND
+              nombre LIKE $2
+          ORDER BY contador DESC
+          LIMIT 50", year, prefijo + "%")
+      end
+
+      if !result_set.nil?
+        result_set.each do
+          valor = result_set.read(Int32)
+          nombre = result_set.read(String)
+          datos.push({valor, nombre})
+        end
+        result_set.close
+      end
+    end
+
+    puts "Data gathered"
+
+    if datos.empty?
+      # This is bad 😀
+      return {
+        body:        "Que raro, no tengo *idea*!",
+        status_code: 200,
+        headers:     HTTP::Headers{"Content-Type" => "text/html"},
+      }
+    end
+
+    # In this context, remove all composite names
+    datos.reject! { |row|
+      row[1].to_s.includes? " "
+    }
+
+    if genero
+      DB.open(DB_URL) do |cursor|
+        datos.reject! { |row|
+          # How feminine is this name?
+          # Yes this database is upper case
+          puts "Checking #{row[0]} #{row[1]}"
+          feminidad = 0
+          sql = %(
+            SELECT COALESCE((SELECT frecuencia FROM mujeres WHERE nombre='#{row[1]?.to_s.upcase}'), 0) AS mujeres,
+                   COALESCE((SELECT frecuencia FROM hombres WHERE nombre='#{row[1]?.to_s.upcase}'), 0) AS hombres
+          )
+          puts "SQL: #{sql}"
+          cursor.query sql do |result_set|
+            result_set.each do
+              mujeres = result_set.read(Int32)
+              hombres = result_set.read(Int32)
+              puts "frecuencias: #{mujeres} #{hombres}"
+              if hombres == mujeres == 0
+                feminidad = 0.5
+              else
+                feminidad = mujeres / (hombres + mujeres)
+              end
+            end
+          end
+          # El overlap en 0.5 es intencional!
+          if (feminidad >= 0.5 && genero == "f") ||
+             (feminidad <= 0.5 && genero == "m")
+            false
+          else
+            true
+          end
+        }
+        puts "Data split by gender"
+      end
+    end
+    datos = datos[..10]
+
+    if datos.size > 1
+      title = "¿Puede ser ... #{datos[0][1].to_s.titleize}? ¿O capaz que #{datos[1][1].to_s.titleize}? ¡Contame más!"
+    elsif datos.size == 1
+      title = "Me parece que ... #{datos[0][1].to_s.titleize}!"
+    else
+      title = "No tengo idea!"
+    end
+
+    buffer = IO::Memory.new
+    Ishi.new(buffer) do
+      x = (0..datos.size - 1).to_a
+      y = datos.map { |row|
+        row[0].to_f / 1000
+      }
+      yrange(0..(y.max*1.1).to_i + 1)
+
+      xtics = Hash(Float64, String).new
+      datos.each_with_index { |row, i|
+        xtics[i.to_f] = row[1].to_s.titleize
+      }
+
+      canvas_size(800, 300)
+      plot(x, y, style: :boxes, fs: 0.25)
+        .boxwidth(0.5)
+        .show_key(false)
+        .ylabel("Popularidad (miles)")
+        .xtics(xtics)
+    end
+
+    {
+      body:        format_buffer(buffer, "busqueda", title),
+      status_code: 200,
+      headers:     HTTP::Headers{"Content-Type" => "text/html"},
+    }
+  end
+end

old-busqueda/shard.yml

@@ -1,6 +1,8 @@
-name: historico
+name: busqueda
 version: 0.1.0
 
 dependencies:
     ishi:
       github: toddsundsted/ishi
+    pg:
+      github: will/crystal-pg    

tapas/funko.py

@@ -1,10 +1,12 @@
-from json import loads
+from flask import Flask, request
 from tapita import Cover
 from io import BytesIO
 import base64
 
+app = Flask("tapas")
 
-def handle(req):
+@app.route('/', methods=['POST'])
+def handle():
     """handle a request to the function
     Args:
         req (str): request body
@@ -15,10 +17,10 @@ def handle(req):
         "author": "bat",
     }
     """
-    if not req:
+    if not request:
         return "Foo", 200, {"Content-Type": "text/plain"}
     try:
-        args = loads(req)
+        args = request.json
     except Exception:
         return "Bad Request", 400
 
@@ -31,3 +33,9 @@ def handle(req):
         200,
         {"Content-Type": "text/html"},
     )
+
+@app.route('/ping')
+def ping():
+    return "OK"
+
+

tapas/funko.yml

@@ -0,0 +1,18 @@
+name: tapas
+runtime: flask
+options:
+  ship_packages: 
+    - jpeg
+    - zlib
+    - freetype
+  devel_packages:
+    - zlib-dev
+    - jpeg-dev
+    - freetype-dev
+  healthcheck_options: "--interval=1m --timeout=2s --start-period=2s --retries=3"
+  healthcheck_command: "curl --fail http://localhost:3000/ping || exit 1"
+  copy_from_build:
+    - "static static"
+    - "venv venv"
+    - "run.sh ."
+    - "funko.py ."

tapas/requirements.txt

@@ -1 +1,2 @@
+flask
 tapita

tapas/run.sh

@@ -0,0 +1,2 @@
+#!/bin/sh
+uwsgi  --plugins http,python -H venv --http 0.0.0.0:3000 --master -p 1 -w funko:app

template/crystal-http/Dockerfile

@@ -8,10 +8,10 @@ RUN apk update && apk upgrade && apk add crystal shards openssl-dev ${ADDITIONAL
 
 WORKDIR /home/app
 
-COPY . .
 COPY function/shard.yml shard.yml
 RUN shards install
-RUN crystal build main.cr -o handler -p && strip handler && rm -rf /root/.cache
+COPY . .
+RUN crystal build main.cr -o handler --error-trace -p  && rm -rf /root/.cache
 
 FROM --platform=${TARGETPLATFORM:-linux/amd64} alpine as ship
 ARG ADDITIONAL_PACKAGE
@@ -28,6 +28,7 @@ COPY --from=build /home/app/handler    .
 COPY --from=watchdog /fwatchdog /usr/bin/fwatchdog
 
 ENV fprocess="./handler"
+ENV exec_timeout=30
 EXPOSE 8080
 
 HEALTHCHECK --interval=2s CMD [ -e /tmp/.lock ] || exit 1

template/crystal/Dockerfile

@@ -1,33 +0,0 @@
-FROM --platform=${TARGETPLATFORM:-linux/amd64} ghcr.io/openfaas/of-watchdog:0.9.10 as watchdog
-FROM --platform=${TARGETPLATFORM:-linux/amd64} alpine as build
-
-RUN apk update && apk upgrade
-RUN apk add crystal shards
-RUN apk cache clean
-WORKDIR /home/app
-COPY . .
-
-COPY function/shard.yml shard.yml
-RUN shards install
-RUN crystal build main.cr -o handler --release --static
-RUN strip handler
-
-FROM --platform=${TARGETPLATFORM:-linux/amd64} alpine as ship
-RUN apk update && apk upgrade && apk cache clean
-# Add non root user
-# Add non root user
-RUN addgroup -S app && adduser app -S -G app
-
-WORKDIR /home/app
-USER app
-
-COPY --from=build /home/app/function/  .
-COPY --from=build /home/app/handler    .
-COPY --from=watchdog /fwatchdog /home/app/fwatchdog
-
-ENV fprocess="./handler"
-EXPOSE 8080
-
-HEALTHCHECK --interval=2s CMD [ -e /tmp/.lock ] || exit 1
-
-CMD ["./fwatchdog"]

template/crystal/function/handler.cr

@@ -1,7 +0,0 @@
-require "json"
-
-class Handler
-  def run(req : String)
-    return JSON::Any.new("Hello, Crystal. You said: #{req}")
-  end
-end

template/crystal/function/shard.yml

@@ -1,7 +0,0 @@
-name: crystal_faas_function
-version: 0.1.0
-
-# dependencies:
-#   pg:
-#     github: will/crystal-pg
-#     version: "~> 0.5"

template/crystal/main.cr

@@ -1,11 +0,0 @@
-# Copyright (c) Thomas Peikert 2018. All rights reserved.
-# Licensed under the MIT license. See LICENSE file in the project root for full license information.
-
-require "json"
-require "./function/handler"
-
-req = STDIN.gets_to_end
-handler = Handler.new
-res = handler.run req
-
-puts res

template/crystal/template.yml

@@ -1,6 +0,0 @@
-language: crystal
-fprocess: ./handler
-welcome_message: |
-  You have created a new function which uses crystal 1.7.3 🎉
-  To include third-party dependencies, use a vendoring tool like shards:
-  shards documentation: https://github.com/crystal-lang/shards

template/python3-fastapi/Dockerfile

@@ -0,0 +1,49 @@
+FROM --platform=${TARGETPLATFORM:-linux/amd64} ghcr.io/openfaas/of-watchdog:0.9.10 as watchdog
+FROM --platform=${TARGETPLATFORM:-linux/amd64} python:3.11-alpine
+
+COPY --from=watchdog /fwatchdog /usr/bin/fwatchdog
+RUN chmod +x /usr/bin/fwatchdog
+
+ARG ADDITIONAL_PACKAGE
+RUN apk --no-cache add musl-dev gcc make ${ADDITIONAL_PACKAGE}
+
+# Add non root user
+RUN addgroup -S app && adduser app -S -G app
+RUN chown app /home/app
+
+USER app
+
+ENV PATH=$PATH:/home/app/.local/bin
+
+WORKDIR /home/app/
+
+COPY requirements.txt   .
+USER root
+RUN pip install -r requirements.txt
+USER app
+COPY index.py           .
+
+RUN mkdir -p function
+RUN touch ./function/__init__.py
+WORKDIR /home/app/function/
+COPY function/requirements.txt	.
+RUN pip install --user -r requirements.txt
+
+WORKDIR /home/app/
+
+USER root
+# remove build dependencies
+RUN apk del musl-dev gcc make
+COPY function function
+RUN chown -R app:app ./
+USER app
+
+ENV fprocess="uvicorn index:app --workers 1 --host 0.0.0.0 --port 8000"
+
+ENV cgi_headers="true"
+ENV mode="http"
+ENV upstream_url="http://127.0.0.1:8000"
+
+HEALTHCHECK --interval=5s CMD [ -e /tmp/.lock ] || exit 1
+
+CMD ["fwatchdog"]

template/python3-fastapi/function/handler.py

@@ -0,0 +1,51 @@
+# author: Justin Guese, 11.3.22, justin@datafortress.cloud
+from fastapi import HTTPException
+from fastapi import APIRouter
+from pydantic import BaseModel
+from typing import Dict, List
+from os import environ
+import glob
+
+# reads in secrets to environment variables, such that they can be 
+# easily used with environ["SECRET_NAME"]
+def readSecretToEnv(secretpath):
+    secretname = secretpath.split('/')[-1]
+    with open(secretpath, "r") as f:
+        environ[secretname] = f.read()
+for secret in glob.glob("/var/openfaas/secrets/*"):
+    readSecretToEnv(secret)
+
+router = APIRouter()
+
+# just as an example
+class User(BaseModel):
+    id: int
+    name: str
+    age: int
+    colleagues: List[str]
+
+class ResponseModel(BaseModel):
+    data: Dict
+    # user: User
+    # otherStuff: str
+
+@router.post("/", response_model = ResponseModel, tags=["Main Routes"])
+def handle(request: Dict):
+    """handle a request to the function
+    Args:
+        req (dict): request body
+    """
+    try:
+        res = ResponseModel(data=request)
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(repr(e)))
+    return res
+
+@router.get("/", response_model = ResponseModel, tags=["Main Routes"])
+def get():
+    return ResponseModel(data={"message": "Hello from OpenFAAS!"})
+
+# again just as an example, delete this if not required
+@router.get("/users/{user_id}", response_model = User, tags=["Main Routes"])
+def getUser(user_id: int):
+    return User(id = user_id, name="Exampleuser", age=20, colleagues=["Colleague 1", "Colleague 2"])

template/python3-fastapi/index.py

@@ -0,0 +1,19 @@
+# author: Justin Guese, 11.3.22, justin@datafortress.cloud
+from os import environ
+import glob
+from fastapi import FastAPI, Request
+from fastapi.openapi.docs import get_swagger_ui_html
+from function.handler import router
+
+app = FastAPI()
+app.include_router(router)
+
+# required to render /docs path
+@app.get("/docs", include_in_schema=False)
+async def custom_swagger_ui_html(req: Request):
+    root_path = req.scope.get("root_path", "").rstrip("/")
+    openapi_url = root_path + app.openapi_url
+    return get_swagger_ui_html(
+        openapi_url=openapi_url,
+        title="API",
+    )

template/python3-fastapi/requirements.txt

@@ -0,0 +1,2 @@
+fastapi
+uvicorn

template/python3-fastapi/template.yml

@@ -0,0 +1,2 @@
+language: python3-fastapi
+fprocess: uvicorn index:app --workers 1 --host 0.0.0.0 --port 8000