feat(libxmf): expose libvpx,add rust examples with it

.gitignore

@@ -16,3 +16,4 @@ package/
 output.*
 capture_sample*
 launchSettings.json
+./examples/

libxmf/CMakeLists.txt

@@ -14,6 +14,11 @@ set(${MODULE_PREFIX}_SOURCES
     XmfNamedPipe.c
     XmfRecorder.c
     XmfMuxer.cpp
+    XmfVpxDecoder.c
+    XmfVpxEncoder.c
+    XmfVpxImage.c
+    XmfVpxPacket.c
+    XmfVpxFrame.c
     )
 
 set(${MODULE_PREFIX}_HEADERS
@@ -30,6 +35,11 @@ set(${MODULE_PREFIX}_HEADERS
     XmfNamedPipe.h
     XmfRecorder.h
     XmfMuxer.h
+    XmfVpxDecoder.h
+    XmfVpxEncoder.h
+    XmfVpxImage.h
+    XmfVpxPacket.h
+    XmfVpxFrame.h
     )
 
 set(${MODULE_PREFIX}_RESOURCES "")

libxmf/XmfVpxDecoder.c

@@ -0,0 +1,103 @@
+#include "XmfVpxDecoder.h"
+#include <stdlib.h>
+#include <string.h>
+#include <vpx/vp8dx.h>
+#include <vpx/vpx_decoder.h>
+#include "XmfVpxImage.h"
+
+// Internal decoder structure
+struct xmf_vpx_decoder
+{
+    vpx_codec_ctx_t codec;
+    XmfVpxDecoderError lastError;
+};
+
+XmfVpXDecoder *XmfVpxDecoder_Create(XmfVpxDecoderConfig cfg)
+{
+
+    XmfVpXDecoder *decoder = (XmfVpXDecoder *)calloc(1, sizeof(XmfVpXDecoder));
+    if (!decoder)
+    {
+        return NULL;
+    }
+
+    decoder->lastError.code = NO_ERROR;
+
+    vpx_codec_dec_cfg_t dec_cfg = {
+        .threads = cfg.threads,
+        .w = cfg.w,
+        .h = cfg.h};
+
+    vpx_codec_iface_t *iface = (cfg.codec == VP8) ? vpx_codec_vp8_dx() : vpx_codec_vp9_dx();
+
+    vpx_codec_err_t res = vpx_codec_dec_init(&decoder->codec, iface, &dec_cfg, 0);
+    if (res != VPX_CODEC_OK)
+    {
+        free(decoder);
+        return NULL;
+    }
+
+    return decoder;
+}
+
+int XmfVpxDecoder_Decode(XmfVpXDecoder *decoder, const uint8_t *data, unsigned int size)
+{
+    if (!decoder || !data || size == 0)
+    {
+        return -1;
+    }
+
+    vpx_codec_err_t res = vpx_codec_decode(&decoder->codec, data, size, NULL, 0);
+    if (res != VPX_CODEC_OK)
+    {
+        decoder->lastError.code = DECODE_ERROR;
+        decoder->lastError.detail.vpx_error.error_code = res;
+        return -1;
+    }
+
+    decoder->lastError.code = NO_ERROR;
+    return 0;
+}
+
+XmfVpxImage *XmfVpxDecoder_GetNextFrame(XmfVpXDecoder *decoder)
+{
+    if (!decoder)
+    {
+        return NULL;
+    }
+
+    vpx_codec_iter_t itr = NULL;
+    vpx_image_t *image = vpx_codec_get_frame(&decoder->codec, &itr);
+    if (!image)
+    {
+        decoder->lastError.code = NO_FRAME_AVAILABLE;
+        return NULL;
+    }
+
+    decoder->lastError.code = NO_ERROR;
+    XmfVpxImage *result = XmfVpxImage_Create(image);
+    return result;
+}
+
+XmfVpxDecoderError XmfVpxDecoder_GetLastError(XmfVpXDecoder *decoder)
+{
+    XmfVpxDecoderError error = {0};
+    if (decoder)
+    {
+        error = decoder->lastError;
+    }
+    else
+    {
+        error.code = MEMORY_ERROR;
+    }
+    return error;
+}
+
+void XmfVpxDecoder_Destroy(XmfVpXDecoder *decoder)
+{
+    if (decoder)
+    {
+        vpx_codec_destroy(&decoder->codec);
+        free(decoder);
+    }
+}

libxmf/XmfVpxDecoder.h

@@ -0,0 +1,102 @@
+#ifndef XMF_VPXDECODER_H
+#define XMF_VPXDECODER_H
+
+#include <stdint.h>
+#include "vpx/vpx_codec.h"
+#include "xmf/xmf.h"
+#include "XmfVpxImage.h"
+
+typedef struct xmf_vpx_decoder XmfVpXDecoder;
+
+typedef enum
+{
+    VP8,
+    VP9,
+} XmfVpxCodecType;
+
+typedef struct xmf_vpx_decoder_config
+{
+    uint32_t threads; /**< Maximum number of threads to use, default 1 */
+    uint32_t w;       /**< Width (set to 0 if unknown) */
+    uint32_t h;       /**< Height (set to 0 if unknown) */
+    XmfVpxCodecType codec;
+} XmfVpxDecoderConfig;
+
+typedef enum xmf_vpx_decoder_error_code
+{
+    NO_ERROR = 0,
+    MEMORY_ERROR = 1,
+    INIT_ERROR = 2,
+    DECODE_ERROR = 3,
+    NO_FRAME_AVAILABLE = 4,
+    VPX_ERROR = 5,
+} XmfVpxDecoderErrorCode;
+
+/**
+ * @brief Error information for the decoder.
+ * 
+ * When the error code is of enum XmfVpxDecoderErrorCode::VPX_ERROR, the union detail.vpx_error.error_code is set to the VPX error code.
+ */
+typedef struct xmf_vpx_decoder_error
+{
+    XmfVpxDecoderErrorCode code;
+    union
+    {
+        struct
+        {
+            vpx_codec_err_t error_code;
+        } vpx_error;
+    } detail;
+} XmfVpxDecoderError;
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif
+
+    /**
+     * @brief Creates and initializes a VPX decoder.
+     *
+     * @param cfg Pointer to the decoder configuration.
+     * @return Pointer to the decoder instance, or NULL on failure.
+     */
+    XMF_EXPORT XmfVpXDecoder *XmfVpxDecoder_Create(XmfVpxDecoderConfig cfg);
+
+    /**
+     * @brief Decodes compressed data.
+     *
+     * @param ctx Pointer to the decoder instance.
+     * @param data Compressed data buffer.
+     * @param size Size of the data buffer.
+     * @return 0 on success, -1 on failure.
+     */
+    XMF_EXPORT int XmfVpxDecoder_Decode(XmfVpXDecoder *ctx, const uint8_t *data, unsigned int size);
+
+    /**
+     * @brief Retrieves the next decoded frame.
+     *
+     * @param ctx Pointer to the decoder instance.
+     * @return Pointer to the decoded image, or NULL if no frame is available.
+     */
+    XMF_EXPORT XmfVpxImage *XmfVpxDecoder_GetNextFrame(XmfVpXDecoder *ctx);
+
+    /**
+     * @brief Retrieves the last error that occurred in the decoder.
+     *
+     * @param ctx Pointer to the decoder instance.
+     * @return The last error information.
+     */
+    XMF_EXPORT XmfVpxDecoderError XmfVpxDecoder_GetLastError(XmfVpXDecoder *ctx);
+
+    /**
+     * @brief Destroys the decoder and frees associated resources.
+     *
+     * @param ctx Pointer to the decoder instance.
+     */
+    XMF_EXPORT void XmfVpxDecoder_Destroy(XmfVpXDecoder *ctx);
+
+#ifdef __cplusplus
+}
+#endif
+
+#endif /* XMF_VPXDECODER_H */