blinkchain

#include <limits.h>
#include <stdlib.h>
#include <stdint.h>
#include <stdbool.h>
#include <string.h>
#include <errno.h>
#include <err.h>

#include "rpi_ws281x/ws2811.h"
#include "base64.h"
#include "port_interface.h"

typedef struct {
  uint16_t width;
  uint16_t height;
  uint16_t *topology;
} canvas_t;

int32_t min(int32_t a, int32_t b) {
  return (a < b) ? a : b;
}

int32_t max(int32_t a, int32_t b) {
  return (a > b) ? a : b;
}

int parse_strip_type(char *strip_type) {
  if (!strncasecmp("rgb", strip_type, 4))
    return WS2811_STRIP_RGB;
  else if (!strncasecmp("rbg", strip_type, 4))
    return WS2811_STRIP_RBG;
  else if (!strncasecmp("grb", strip_type, 4))
    return WS2811_STRIP_GRB;
  else if (!strncasecmp("gbr", strip_type, 4))
    return WS2811_STRIP_GBR;
  else if (!strncasecmp("brg", strip_type, 4))
    return WS2811_STRIP_BRG;
  else if (!strncasecmp("bgr", strip_type, 4))
    return WS2811_STRIP_BGR;
  else if (!strncasecmp("rgbw", strip_type, 4))
    return SK6812_STRIP_RGBW;
  else if (!strncasecmp("rbgw", strip_type, 4))
    return SK6812_STRIP_RBGW;
  else if (!strncasecmp("grbw", strip_type, 4))
    return SK6812_STRIP_GRBW;
  else if (!strncasecmp("gbrw", strip_type, 4))
    return SK6812_STRIP_GBRW;
  else if (!strncasecmp("brgw", strip_type, 4))
    return SK6812_STRIP_BRGW;
  else if (!strncasecmp("bgrw", strip_type, 4))
    return SK6812_STRIP_BGRW;
  else
    errx(EXIT_FAILURE, "Invalid strip type %s\n", strip_type);
}

void init_canvas(canvas_t *canvas) {
  uint16_t width, height;
  char nl;
  if (scanf("%hu %hu%c", &width, &height, &nl) != 3 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  debug("Called init_canvas(width: %hu, height: %hu)", width, height);
  canvas->width = width;
  canvas->height = height;
  if (canvas->topology != NULL) {
    free(canvas->topology);
  }
  canvas->topology = malloc(width * height * sizeof(uint16_t));
  // Initialize all offsets to USHRT_MAX
  memset(canvas->topology, 0xFF, width * height * sizeof(uint16_t));
  reply_ok();
}

void init_pixels(canvas_t *canvas) {
  uint16_t x, y, count, offset;
  uint8_t channel;
  int8_t dx, dy;
  char nl;
  if (scanf("%hhu %hu %hu %hu %hu %hhi %hhi%c", &channel, &offset, &x, &y, &count, &dx, &dy, &nl) != 8 || nl != '\n') {
    reply_error("Argument error");
  }
  debug("Called init_pixels(channel: %hhu, offset: %hu, x: %hu, y: %hu, count: %hu, dx: %hhi, dy: %hhi)", channel, offset, x, y, count, dx, dy);
  if (offset + count - 1 >= 32767) { // 0xEFFF
    reply_error("The offset of the last pixel in each channel must be less than 32767.");
    return;
  }
  if (min(x, x + (count - 1) * dx) < 0 || max(x, x + (count - 1) * dx) >= canvas->width ||
      min(y, y + (count - 1) * dy) < 0 || max(y, y + (count - 1) * dy) >= canvas->height) {
    reply_error("Pixels must all be within the bounds of the canvas");
    return;
  }
  // MSB designates which channel to use
  offset |= (channel << 15);
  uint16_t i;
  for (i = 0; i < count; i++) {
    debug("  Setting topology(%hu, %hu) to %hu", x, y, offset);
    canvas->topology[(canvas->width * y) + x] = offset++;
    x += dx;
    y += dy;
  }
  reply_ok();
}

void set_invert(ws2811_channel_t *channels) {
  uint8_t channel, invert;
  char nl;
  if (scanf("%hhu %hhu%c", &channel, &invert, &nl) != 3 || nl != '\n') {
    reply_error("Argument error in set_invert command");
    return;
  }
  debug("Called set_invert(channel: %hhu, invert: %hhu)", channel, invert);
  if(channel > 1) {
    reply_error("Channel must be 0 or 1");
    return;
  }
  if(invert > 1) {
    reply_error("Invert must be 0 or 1");
    return;
  }
  channels[channel].invert = invert;
  reply_ok();
}

void set_brightness(ws2811_channel_t *channels) {
  uint8_t channel, brightness;
  char nl;
  if (scanf("%hhu %hhu%c", &channel, &brightness, &nl) != 3 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  if(channel > 1) {
    reply_error("Channel must be 0 or 1");
    return;
  }
  debug("Called set_brightness(channel: %hhu, brightness: %hhu)", channel, brightness);
  channels[channel].brightness = brightness;
  reply_ok();
}

void set_gamma(ws2811_channel_t *channels) {
  uint8_t channel;
  uint32_t base64_size = 256 * 4 * 4 / 3; // Each color channel has 256 bytes, scaled by 4/3 for Base64
  char *base64_buffer = malloc(base64_size + 1);
  char format[16], nl;
  sprintf(format, "%%hhu %%%us%%c", base64_size);
  if (scanf(format, &channel, base64_buffer, &nl) != 3 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  int decoded_size;
  uint8_t *data = unbase64(base64_buffer, strlen(base64_buffer), &decoded_size);
  free(base64_buffer);
  if (decoded_size != 4 * 256) {
    reply_error("Size of gamma table must be 4 * 256 bytes");
  }
  else if (channel > 1) {
    reply_error("Channel must be 0 or 1");
  }
  else {
    debug("Called set_gamma(channel: %hhu, gamma: <binary>)", channel);
    channels[channel].gamma = data;
    reply_ok();
  }
  free(data);
}

ws2811_led_t read_pixel(uint16_t x, uint16_t y, ws2811_channel_t *channels, const canvas_t *canvas) {
  uint16_t offset = canvas->topology[(canvas->width * y) + x];
  ws2811_led_t color;
  // Ignore canvas locations that weren't initialized with pixels
  if (offset == USHRT_MAX) {
    // TODO: We should probably store the whole canvas instead of just the
    // actually-mapped pixels in the topology so we don't have to do this...
    // and maybe use OpenGL ES or something to do the low-level drawing.
    color = (ws2811_led_t) 0x00000000;
  } else {
    // MSB designates which channel to use
    uint8_t channel = offset >> 15;
    // Clear the MSB so we can use pixel as the offset within the channel
    offset &= ~(1 << 15);
    color = channels[channel].leds[offset];
  }
  debug("  - read_pixel(x: %hu, y: %hu) => 0x%08x", x, y, color);
  return color;

}

void write_pixel(uint16_t x, uint16_t y, ws2811_led_t color, ws2811_channel_t *channels, const canvas_t *canvas) {
  debug("  - write_pixel(x: %hu, y: %hu, color: 0x%08x)", x, y, color);
  uint16_t offset = canvas->topology[(canvas->width * y) + x];
  // Ignore canvas locations that weren't initialized with pixels
  if (offset != USHRT_MAX) {
    // MSB designates which channel to use
    uint8_t channel = offset >> 15;
    // Clear the MSB so we can use pixel as the offset within the channel
    offset &= ~(1 << 15);
    channels[channel].leds[offset] = color;
  }
}

void get_pixel(ws2811_channel_t *channels, const canvas_t *canvas) {
  uint16_t x, y;
  char nl;
  if (scanf("%hu %hu%c", &x, &y, &nl) != 3 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  debug("Called get_pixel(x: %hu, y: %hu)", x, y);
  if (x + 1 > canvas->width || y + 1 > canvas->height) {
    reply_error("Cannot read from outside canvas dimensions");
    return;
  }
  reply_ok_payload("0x%08x", read_pixel(x, y, channels, canvas));
}

void set_pixel(ws2811_channel_t *channels, const canvas_t *canvas) {
  uint16_t x, y;
  uint8_t r, g, b, w;
  char nl;
  if (scanf("%hu %hu %hhu %hhu %hhu %hhu%c", &x, &y, &r, &g, &b, &w, &nl) != 7 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  // ws2811_led_t is uint32_t: 0xWWRRGGBB
  ws2811_led_t color = (w << 24) | (r << 16) | (g << 8) | b;
  debug("Called set_pixel(x: %hu, y: %hu, color: 0x%08x)", x, y, color);
  if (x + 1 > canvas->width || y + 1 > canvas->height) {
    reply_error("Cannot draw outside canvas dimensions");
    return;
  }
  write_pixel(x, y, color, channels, canvas);
  reply_ok();
}

void fill(ws2811_channel_t *channels, const canvas_t *canvas) {
  uint16_t x, y, width, height;
  uint8_t r, g, b, w;
  char nl;
  if (scanf("%hu %hu %hu %hu %hhu %hhu %hhu %hhu%c", &x, &y, &width, &height, &r, &g, &b, &w, &nl) != 9 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  // ws2811_led_t is uint32_t: 0xWWRRGGBB
  ws2811_led_t color = (w << 24) | (r << 16) | (g << 8) | b;
  debug("Called fill(x: %hu, y: %hu, width: %hu, height: %hu, color: 0x%08x)", x, y, width, height, color);
  if (x + width > canvas->width || y + height > canvas->height) {
    reply_error("Cannot draw outside canvas dimensions");
    return;
  }
  uint16_t row, col;
  for(row = 0; row < height; row++) {
    for(col = 0; col < width; col++) {
      write_pixel(x + col, y + row, color, channels, canvas);
    }
  }
  reply_ok();
}

void copy(bool copy_null, ws2811_channel_t *channels, const canvas_t *canvas) {
  uint16_t xs, ys, xd, yd, width, height;
  char nl;
  if (scanf("%hu %hu %hu %hu %hu %hu%c", &xs, &ys, &xd, &yd, &width, &height, &nl) != 7 || nl != '\n') {
    reply_error("Argument error");
    return;
  }
  debug("Called copy%s(xs: %hu, ys: %hu, xd: %hu, yd: %hu, width: %hu, height: %hu)", copy_null ? "" : "_blit", xs, ys, xd, yd, width, height);
  if (xs + width > canvas->width || ys + height > canvas->height || xd + width > canvas->width || yd + height > canvas->height) {
    reply_error("Cannot draw outside canvas dimensions");
    return;
  }
  uint16_t row, col;
  ws2811_led_t *buffer = calloc(width * height, sizeof(ws2811_led_t));;
  for(row = 0; row < height; row++) {
    for(col = 0; col < width; col++) {
      buffer[row * width + col] = read_pixel(xs + col, ys + row, channels, canvas);
    }
  }
  // We have to copy to a temporary buffer and then back so that the copy happens "all at once."
  ws2811_led_t color;
  for(row = 0; row < height; row++) {
    for(col = 0; col < width; col++) {
      color = buffer[row * width + col];
      if (color != 0x00000000 || copy_null)
        write_pixel(xd + col, yd + row, color, channels, canvas);
    }
  }
  reply_ok();
}

void blit(ws2811_channel_t *channels, const canvas_t *canvas) {
  uint16_t x, y, width, height;
  uint32_t base64_size;
  if (scanf("%hu %hu %hu %hu %u ", &x, &y, &width, &height, &base64_size) != 5) {
    reply_error("Argument error");
    return;
  }
  char format[16], nl;
  sprintf(format, "%%%us%%c", base64_size);
  char *base64_buffer = malloc(base64_size + 1);
  if (scanf(format, base64_buffer, &nl) != 2 || nl != '\n') {
    free(base64_buffer);
    reply_error("Unable to read base64-encoded binary");
    return;
  }
  debug("Called blit(x: %hu, y: %hu, width: %hu, height: %hu, data: %s)", x, y, width, height, base64_buffer);

  int decoded_size;
  uint8_t *data = unbase64(base64_buffer, strlen(base64_buffer), &decoded_size);
  free(base64_buffer);
  // Each pixel should have 4 8-bit color channels
  if (decoded_size != width * height * 4) {
    reply_error("Size of binary data didn't match the width and height");
  }
  else if (x + width > canvas->width || y + height > canvas->height) {
    reply_error("Cannot draw outside canvas dimensions");
  }
  else {
    uint16_t row, col, offset = 0;
    ws2811_led_t color;
    for(row = 0; row < height; row++) {
      for(col = 0; col < width; col++, offset += 4) {
        // ws2811_led_t is uint32_t: 0xWWRRGGBB
        // so data should look like [0xWW, 0xRR, 0xGG, 0xBB]
        color = data[offset] << 24 | data[offset + 1] << 16 | data[offset + 2] << 8 | data[offset + 3];
        // Ignore totally black pixels in the source image to allow simple sprite masking.
        if (color != 0x00000000)
          write_pixel(x + col, y + row, color, channels, canvas);
      }
    }
    reply_ok();
  }
  free(data);
}

int main(int argc, char *argv[]) {
  if (argc != 8 && argc != 5)
    errx(EXIT_FAILURE, "Usage: %s <DMA Channel> <Channel 1 Pin> <Channel 1 Count> <Channel 1 Type> [<Channel 2 Pin> <Channel 2 Count> <Channel 2 Type>]", argv[0]);

  uint8_t dma_channel = atoi(argv[1]);
  uint8_t gpio_pin1 = atoi(argv[2]);
  uint32_t led_count1 = strtol(argv[3], NULL, 10);
  int strip_type1 = parse_strip_type(argv[4]);

  uint8_t gpio_pin2 = 0;
  uint32_t led_count2 = 0;
  int strip_type2 = WS2811_STRIP_GBR;
  if (argc == 8) {
    gpio_pin2 = atoi(argv[5]);
    led_count2 = strtol(argv[6], NULL, 10);
    strip_type2 = parse_strip_type(argv[7]);
  }

  /*
  Setup the channels. Raspberry Pi supports 2 PWM channels.
  */
  ws2811_t ledstring = {
    .freq = WS2811_TARGET_FREQ,
    .dmanum = dma_channel,
    .channel = {
      [0] = {
        .gpionum = gpio_pin1,
        .count = led_count1,
        .invert = 0,
        .brightness = 255,
        .strip_type = strip_type1,
      },
      [1] = {
        .gpionum = gpio_pin2,
        .count = led_count2,
        .invert = 0,
        .brightness = 255,
        .strip_type = strip_type2,
      },
    },
  };

  ws2811_return_t rc = ws2811_init(&ledstring);
  if (rc != WS2811_SUCCESS)
    errx(EXIT_FAILURE, "ws2811_init failed: %d (%s)", rc, ws2811_get_return_t_str(rc));

  canvas_t canvas = {
    .width = 0,
    .height = 0,
    .topology = NULL,
  };

  char buffer[16];
  for (;;) {
    buffer[0] = '\0';
    if (scanf("%15s", buffer) == 0 || strlen(buffer) == 0) {
      if (feof(stdin)) {
        debug("EOF");
        exit(EXIT_SUCCESS);
      } else {
        errx(EXIT_FAILURE, "read error");
      }
    }

    if (strcasecmp(buffer, "init_canvas") == 0) {
      init_canvas(&canvas);

    } else if (strcasecmp(buffer, "init_pixels") == 0) {
      init_pixels(&canvas);

    } else if (strcasecmp(buffer, "set_invert") == 0) {
      set_invert(ledstring.channel);

    } else if (strcasecmp(buffer, "set_brightness") == 0) {
      set_brightness(ledstring.channel);

    } else if (strcasecmp(buffer, "set_gamma") == 0) {
      set_gamma(ledstring.channel);

    } else if (strcasecmp(buffer, "set_pixel") == 0) {
      set_pixel(ledstring.channel, &canvas);

    } else if (strcasecmp(buffer, "get_pixel") == 0) {
      get_pixel(ledstring.channel, &canvas);

    } else if (strcasecmp(buffer, "fill") == 0) {
      fill(ledstring.channel, &canvas);

    } else if (strcasecmp(buffer, "copy") == 0) {
      copy(true, ledstring.channel, &canvas);

    } else if (strcasecmp(buffer, "blit") == 0) {
      blit(ledstring.channel, &canvas);

    } else if (strcasecmp(buffer, "copy_blit") == 0) {
      copy(false, ledstring.channel, &canvas);

    } else if (strcasecmp(buffer, "render") == 0) {
      ws2811_return_t result = ws2811_render(&ledstring);
      if (result != WS2811_SUCCESS)
        errx(EXIT_FAILURE, "ws2811_render failed: %d (%s)", result, ws2811_get_return_t_str(result));
      reply_ok();

    } else if (strcasecmp(buffer, "print_topology") == 0) {
      debug("Called print_topology()");
      uint16_t x, y, offset;
      for(y = 0; y < canvas.height; y++) {
        for(x = 0; x < canvas.width; x++) {
          offset = canvas.topology[(canvas.width * y) + x];
          if (offset == USHRT_MAX) {
            debug("  [%hu][%hu]: [  -  ]", x, y);
          } else {
            debug("  [%hu][%hu]: [%5hu]", x, y, offset);
          }
        }
      }
      reply_ok();

    } else {
      reply_error("Unrecognized command: '%s'", buffer);
    }
  }
}