Skill UI

A comprehensive guide for building robust, event-driven APIs using Webhooks, Server-Sent Events (SSE), and message brokers (e.g., Kafka, RabbitMQ). This skill covers advanced patterns like the transactional outbox pattern, implementing event schemas, managing webhooks with retry logic, and establishing real-time streaming endpoints for asynchronous microservices communication. Ideal for architecting complex, scalable, and resilient systems.

This skill is designed for advanced error detective work. It analyzes complex log streams, correlates stack traces across distributed systems, and detects anomalous error patterns. It helps identify root causes by correlating errors with system deployments and changes, providing actionable findings for immediate fixes and long-term prevention strategies.

Provides expert guidance on secure and performant file upload mechanisms for cloud environments. Covers best practices for using services like AWS S3 and Cloudflare R2, including implementing presigned URLs, handling large files via streaming, and optimizing images. Crucially emphasizes critical security measures such as validating file types using magic bytes, enforcing size limits, and preventing path traversal attacks.

A comprehensive guide to building scalable, event-driven architectures using the Groq API. Learn advanced patterns including Server-Sent Events (SSE) for real-time streaming, batch processing with job queues (e.g., BullMQ), and processing incoming webhook events for robust LLM pipelines.

A comprehensive guide to implementing advanced asynchronous patterns with Mistral AI. This skill covers using the Agents API for stateful, multi-turn workflows, the Batch API for cost-effective bulk inference, and event-driven streaming architectures. It is essential for building robust, long-running, or high-volume AI applications that require reliable background job handling.

This guide provides comprehensive documentation and code examples for integrating OpenEvidence webhooks. Learn how to subscribe to real-time events (e.g., query completion, evidence updates, new citations) to keep clinical decision support systems fresh. Use these webhooks to trigger downstream audit workflows and ensure immediate data synchronization.

This skill provides comprehensive guides on implementing real-time streaming responses using OpenRouter's Server-Sent Events (SSE) capability. It covers various languages (Python, TypeScript, FastAPI, JavaScript), enabling developers to build modern, fast-feeling chat interfaces. By streaming tokens as they are generated, it significantly reduces the time-to-first-token (TTFT) and improves user experience for long completions and chat applications.

This skill enables the development of robust, event-driven pipelines interacting with the Perplexity Sonar API. Since Perplexity lacks native webhooks, this system simulates event patterns using advanced techniques: Streaming Server-Sent Events (SSE) for real-time data, job queues (like BullMQ/SQS) for asynchronous batch research, and cron-triggered monitoring for scheduled news and trend alerts. It provides patterns for building complex, reliable, and scalable AI applications.

A guide to building robust projections and read models from continuous event streams. This pattern is essential for implementing CQRS read sides, creating materialized views, optimizing query performance, and building complex search indexes in event-sourced architectures. Use it when data needs to be transformed and aggregated from raw events into optimized query structures.

Specializes in building modern, high-performance Rails 7+ web applications. Expertise includes optimizing Active Record queries (N+1 prevention), implementing partial page updates with Hotwire (Turbo Frames/Streams), handling real-time communication via Action Cable, and managing background jobs using Sidekiq. The process includes rigorous RSpec testing and database schema management.

This pipeline provides an automated solution for processing raw Indicators of Compromise (IOCs) from various sources, including IPs, domains, URLs, and emails. It performs crucial steps such as normalization, deduplication, and defanging (modifying indicators to prevent accidental execution while preserving readability). The final, processed data is converted into the standardized STIX 2.1 format and can be securely distributed via TAXII servers or MISP instances, streamlining threat intelligence sharing.

A type-safe, declarative implementation of ReactiveX in Go. This library enables robust handling of infinite, asynchronous event streams (like WebSockets or tickers) by providing composable operators, automatic backpressure management, and error propagation. It is designed to replace complex, error-prone manual channel and goroutine wiring, allowing developers to build predictable, real-time, event-driven pipelines.