kolibrios/programs/other/Weather/weather.c

/* Copyright (C) 2019-2021 Logaev Maxim (turbocat2001), GPLv2 */

/*
    Info: App uses api from openweathermap.org. 
    The standard configuration uses my token and the city of Moscow. 
    You can always change it in the weather.json file.
    If you use UTF-8 encoding, then city names can be entered in different languages!
*/

#include <stdio.h>
#include <string.h>
#include "json/json.h"
#include <kos32sys1.h>
#include <kolibrisys.h>
#include <clayer/http.h>
#include <clayer/libimg.h>

#define VERSION  "Weather 1.0b"

enum BUTTONS{
    BTN_QUIT = 1,
    BTN_UPDATE = 2
};

#define JSON_OBJ(X) value->u.object.values[X]
#define OK 200
#define API       "http://api.openweathermap.org/data/2.5/weather?q=%s&appid=%s&units=metric"
#define IMAGE_URL "http://openweathermap.org/img/w/%s.png"
#define START_YPOS 34 

Image *image;
char full_url[256];
char full_url_image[256];
struct kolibri_system_colors sys_color_table;

#pragma pack(push,1)
typedef struct {
    char *City;
    float wind_speed;
    //int wind_deg;
    int pressure;
    int humidity;
    char *weath_main;
    char *weath_desc;
    int visibility;
    int timezone;
    char* image_code;
    double temp;
}open_weather_data;
#pragma pack(pop)

open_weather_data myw;

void notify_show(char *text)
{
   start_app("/sys/@notify", text);
}

void* safe_malloc(size_t size) // Безопасный malloc. Показывает уведомление об ошибке и закрывает программу если память не была выделена
{
    void *p=malloc(size);
    if(p==NULL){
       notify_show("'Memory allocation error!' -E");
       exit(0);
    }else{
        return p;
    }
}

static void draw_format_text_sys(int x, int y, color_t color, const char *format_str, ... )
{
    char tmp_buff[100];
    va_list ap;
    va_start (ap, format_str);
    vsnprintf(tmp_buff, sizeof tmp_buff ,format_str, ap);
    va_end(ap);
    draw_text_sys(tmp_buff, x, y , 0, color);
}

void find_and_set(json_value *value, open_weather_data* weather)
{
    for(int i=0; i<value->u.object.length; i++){
        if(!strcmp(JSON_OBJ(i).name, "main")){
            weather->temp = JSON_OBJ(i).value->u.object.values[0].value->u.dbl;
            weather->pressure = JSON_OBJ(i).value->u.object.values[4].value->u.integer;
            weather->humidity = JSON_OBJ(i).value->u.object.values[5].value->u.integer;
        }
        if(!strcmp(JSON_OBJ(i).name, "name")){
            weather->City = JSON_OBJ(i).value->u.string.ptr;
        }
        if(!strcmp(JSON_OBJ(i).name, "weather")){
           weather->weath_desc = JSON_OBJ(i).value->u.array.values[0]->u.object.values[2].value->u.string.ptr;
           weather->image_code = JSON_OBJ(i).value->u.array.values[0]->u.object.values[3].value->u.string.ptr;
        }
        if(!strcmp(JSON_OBJ(i).name, "wind")){
            weather->wind_speed = JSON_OBJ(i).value->u.object.values[0].value->u.dbl;
        }
        if(!strcmp(JSON_OBJ(i).name, "visibility")){
            weather->visibility = JSON_OBJ(i).value->u.integer;
        }
        if(!strcmp(JSON_OBJ(i).name, "timezone")){
            weather->timezone = JSON_OBJ(i).value->u.integer/60/60;
        }
        if(!strcmp(JSON_OBJ(i).name, "message")){
            char *errmsg = safe_malloc(weather->timezone = JSON_OBJ(i).value->u.string.length+6);
            sprintf(errmsg,"'%s!' -E", JSON_OBJ(i).value->u.string.ptr);
            notify_show(errmsg);
        }
    }
}

http_msg* get_json(char *City, char *Token)
{
    sprintf(full_url, API, City, Token);
    http_msg *h = http_get(full_url, 0,  HTTP_FLAG_BLOCK, "");
    http_long_receive(h);
    if (h->status == OK || h->status == 404) {
       return h;
    } else {
        return NULL;
    }
}

void get_image(){
    sprintf(full_url_image, IMAGE_URL, myw.image_code);
    http_msg *h= http_get(full_url_image, 0,  HTTP_FLAG_BLOCK, "");
    http_long_receive(h);
    
    if (h->status == OK) {
        image = img_decode(h->content_ptr, h->content_length, 0); // Decode RAW data to Image data
        if (image->Type != IMAGE_BPP32) { 
            image = img_convert(image, NULL, IMAGE_BPP32, 0, 0); // Convert image to format BPP32
                if (!image) {
                notify_show("'Convetring image error!' -E");  
                exit(0);
            }
        }
        //blend = img_create(64, 64, IMAGE_BPP32);  // Create an empty layer
        //img_fill_color(blend, 64, 64, sys_color_table.work_area); // Fill the layer with one color
        image = img_scale(image, 0, 0, 50, 50, NULL, LIBIMG_SCALE_STRETCH , LIBIMG_INTER_BILINEAR, 64, 64);
        //img_blend(blend, image, 0, 0, 0, 0, 64, 64);  // Blending images to display the alpha channel. 
    }else{
       notify_show("'Image not loaded!!' -W"); 
    }  
}

void RedrawGUI() //Рисуем окно
{
    char buff[1000];
    pos_t win_pos = get_mouse_pos(0); // Получаем координаты курсора
    begin_draw(); //Начинаем рисование интерфейса )
    sys_create_window(win_pos.x, win_pos.y, 220, START_YPOS+200, VERSION, 0xffffff, 0x14); // Создаём окно.

    draw_format_text_sys(10, START_YPOS, 0xB0000000 /*| sys_color_table.work_text*/,  "%s (UTC%+d)\0", myw.City, myw.timezone);
    draw_format_text_sys(11, START_YPOS, 0xB0000000 /*| sys_color_table.work_text */, "%s (UTC%+d)\0", myw.City, myw.timezone);

    img_draw(image, 10, START_YPOS+30, 64,64,0,0);

    draw_format_text_sys(10, START_YPOS+20, 0xb0000000 /* | sys_color_table.work_text */, myw.weath_desc);
    draw_format_text_sys(11, START_YPOS+20, 0xb0000000 /*| sys_color_table.work_text */, myw.weath_desc);

    draw_format_text_sys(90, START_YPOS+45, 0xB1000000 /*| sys_color_table.work_text*/, "%.1f °C", myw.temp);  
    draw_format_text_sys(91, START_YPOS+46, 0xB1000000 /*| sys_color_table.work_text*/, "%.1f °C", myw.temp);

    draw_format_text_sys(10, START_YPOS+80, 0x90000000 /*| sys_color_table.work_text*/,  "Pressure:   %d hPa",myw.pressure);
    draw_format_text_sys(10, START_YPOS+100, 0x90000000 /* | sys_color_table.work_text*/,"Humidity:   %d %s", myw.humidity, "%");
    draw_format_text_sys(10, START_YPOS+120, 0x90000000 /*| sys_color_table.work_text*/, "Wind speed: %.1f m/s", myw.wind_speed);
    draw_format_text_sys(10, START_YPOS+140, 0x90000000 /*| sys_color_table.work_text*/, "Visibility: %d m", myw.visibility);
    
    define_button(X_W(65,80), Y_H(START_YPOS+160,30), BTN_UPDATE, sys_color_table.work_button);
    draw_text_sys("Update",80 , START_YPOS+170, 0, 0x90000000 | sys_color_table.work_button_text);
    end_draw();
}

void get_config(char **City, char **Token)
{
    FILE *config_j = fopen("weather.json", "rb");
    if(config_j==NULL){
        notify_show("'Configuration file not found!' -E");
        exit(0);
    }
    size_t size = _ksys_get_filesize("weather.json");
    char *config_buff = safe_malloc(size+1);
    if(size != fread(config_buff, sizeof(char), size, config_j)){
        notify_show("'The configuration file was not fully read!' -E");
        exit(0);    
    }
    json_value* value =json_parse (config_buff, size);
    for(int i=0; i<value->u.object.length; i++){
        if(!strcmp(JSON_OBJ(i).name, "Location")){   
          *City = JSON_OBJ(i).value->u.string.ptr;
        }
        if(!strcmp(JSON_OBJ(i).name, "Token")){
           *Token = JSON_OBJ(i).value->u.string.ptr;
        }
    }
    if(*City==NULL || *Token ==NULL){
         notify_show("'Invalid config!!' -E");
         exit(0);
    }
    free(config_buff);
}

void Update(char* city, char* token)
{
    memset(&myw, 0, sizeof myw);
    myw.City="None";
    myw.weath_desc="unknown";
    http_msg *json_file = get_json(city, token);
    if(json_file != NULL){
        json_value* value =json_parse (json_file->content_ptr, json_file->content_length);
        find_and_set(value, &myw);
        get_image();
    }else{
        notify_show("'Connection error!' -E");
    }
}

int main(){
    kolibri_libimg_init();
    get_system_colors(&sys_color_table);
    
    char *City = NULL;
    char *Token = NULL;
    get_config(&City, &Token);
    Update(City,Token);
   
    while(1){
        switch(get_os_event()){
            case KOLIBRI_EVENT_NONE:
                break;
            case KOLIBRI_EVENT_REDRAW:
                RedrawGUI();
                break;        
            case KOLIBRI_EVENT_BUTTON: // Событие обработки кнопок
                switch (get_os_button()){
                    case BTN_UPDATE:
                        Update(City, Token);
                        RedrawGUI();
                        break;
                    case BTN_QUIT:
                        exit(0);
                        break;
                }
        }
    }
    return 0;
}