/*
 * FILE:    codec_acm.c
 * PROGRAM: RAT
 * AUTHOR:  O.Hodson
 *
 * Copyright (c) 1995-2001 University College London
 * All rights reserved.
 */
 
#ifndef HIDE_SOURCE_STRINGS
static const char cvsid[] = 
	"$Id: codec_acm.c,v 1.16 2001/01/08 20:29:55 ucaccsp Exp $";
#endif /* HIDE_SOURCE_STRINGS */

#ifdef WIN32
#include "config_win32.h"
#include "codec_acm.h"
#include "codec.h"
#include "memory.h"

static HACMDRIVER hadActive;

#define CODEC_ACM_INPUT  1
#define CODEC_ACM_OUTPUT 2
#define CODEC_ACM_FRAME  4
#define CODEC_ACM_SAMPLE 8

#define CODEC_ACM_NOT_TESTED 0
#define CODEC_ACM_PRESENT    1

typedef struct s_acm_codec {
        char szShortName[32];
        char szRATCodecName[32]; /* This has to match entry in codec.c */
        WORD nSamplesPerSec;
        WORD nChannels;
        WORD nAvgBytesPerSec;
	HACMDRIVERID had;
	WORD status;
        WAVEFORMATEX wfx;
} acm_codec_t;

/* These are codecs in the codec table in codec.c.
 *
* A random curiosity is that the ITU call the upper
* bitrate G723.1 a 6.3kbs coder in all documentation
* whereas microsoft call it 6.4kbs coder and it is :-)
*/

#define ACM_MAX_DYNAMIC 2

acm_codec_t known_codecs[] = {
        {"Microsoft G.723.1", "G723.1(6.3kb/s)", 8000, 1, 800, 0, CODEC_ACM_NOT_TESTED},
        {"Microsoft G.723.1", "G723.1(5.3kb/s)", 8000, 1, 666, 0, CODEC_ACM_NOT_TESTED}
};

static HACMDRIVERID hDrvID[ACM_MAX_DYNAMIC];
static HACMDRIVER   hDrv[ACM_MAX_DYNAMIC];
static int nDrvOpen;

static int 
acmAcceptableRate(int rate) 
{
        /* If you want to add multiples of 11025 this code should not break here */
        static const int smplRates[] = {8000, 16000, 32000, 48000};
        static const int nRates = 4;
        int i;
        for(i = 0; i<nRates; i++)
                if (smplRates[i] == rate) return TRUE;
                return FALSE;
}

static void
acmFrameMetrics(HACMSTREAM has, WORD wBitsPerSample, DWORD dwSamplesPerSec, DWORD dwBytesPerSec, int *piSamplesPerFrame, int *piFrameSize)
{
        DWORD dwSrcSize = wBitsPerSample/8, dwDstSize = 0;
        MMRESULT mmr = 0;
        
        assert(has != NULL);

        while(dwDstSize == 0 && (mmr == 0 || mmr == ACMERR_NOTPOSSIBLE)) {
                dwSrcSize += wBitsPerSample/8;
                mmr = acmStreamSize(has, dwSrcSize, &dwDstSize, ACM_STREAMSIZEF_SOURCE);
        }
        
        (*piFrameSize) = dwDstSize;
        
        /* some codecs return frame size irrespective of source block size (groan!) */
        (*piSamplesPerFrame) = dwSamplesPerSec * dwDstSize / dwBytesPerSec;
}

static ACMDRIVERDETAILS add;

BOOL CALLBACK 
acmFormatEnumProc(HACMDRIVERID hadid, LPACMFORMATDETAILS pafd, DWORD dwInstance, DWORD fdwSupport)
{
        MMRESULT mmr;
        WAVEFORMATEX wfxDst, wfxPCM;
        HACMSTREAM has = 0;
   
        int iIOAvail = 0, i;
        int iType, iSamplesPerFrame = 0, iFrameSize = 0, iFixedHdrSize = 0;
        
        if (/* pafd->pwfx->wFormatTag == WAVE_FORMAT_PCM || */
            !acmAcceptableRate(pafd->pwfx->nSamplesPerSec)) {
                return TRUE;
        }

        /* Copy this because ACM calls can trash it */
        memcpy(&wfxDst, pafd->pwfx, sizeof(WAVEFORMATEX));
        
        /* We use a crude guess at whether format of pafd->pwfx is PCM,
        * only interested in 16-bit (rat's native format) PCM to other 
        * format (and vice-versa) here.
        */
              
        /* This is a dumb test but frame based codecs are inconsistent in their bits per sample reported */
        if ((wfxDst.wBitsPerSample & 0x07)||(wfxDst.nBlockAlign == wfxDst.nChannels * wfxDst.wBitsPerSample/8)) {
                iType = CODEC_ACM_SAMPLE;
        } else   {
                iType = CODEC_ACM_FRAME;
        } 
        
        wfxPCM.wFormatTag      = WAVE_FORMAT_PCM;
        wfxPCM.nChannels       = wfxDst.nChannels;
        wfxPCM.nSamplesPerSec  = wfxDst.nSamplesPerSec;
        wfxPCM.wBitsPerSample  = 16;
        wfxPCM.nBlockAlign     = wfxPCM.nChannels * wfxPCM.wBitsPerSample / 8;
        wfxPCM.nAvgBytesPerSec = wfxPCM.nBlockAlign * wfxPCM.nSamplesPerSec;
        wfxPCM.cbSize          = 0;
        
        mmr = acmStreamOpen(&has, hadActive, &wfxPCM, &wfxDst, NULL, 0L, 0L, 0L);
        
        /* We usually fail because we cannot convert format in real-time, e.g.
        * MPEG Layer III on this machine above 16kHz.  These don't appear
        * to be related to machine type (?).
        */
        if (0 == mmr) {
                iIOAvail |= CODEC_ACM_INPUT;
                switch(iType) {
                case CODEC_ACM_FRAME:
                        /* In nearly all cases Frame size is the same as alignment, but do not assume this */
                        acmFrameMetrics(has, 
                                wfxPCM.wBitsPerSample,
                                wfxPCM.nSamplesPerSec,
                                pafd->pwfx->nAvgBytesPerSec, 
                                &iSamplesPerFrame, 
                                &iFrameSize);
                        break;
                case CODEC_ACM_SAMPLE:
                        
                        break;
                }
                acmStreamClose(has,0); 
                /* There is no corresponding close as we are only querying this fmt */
                mmr = acmStreamOpen(&has, hadActive, &wfxDst, &wfxPCM, NULL, 0L, 0L, ACM_STREAMOPENF_QUERY);
                
                if (0 == mmr) {
                        iIOAvail |= CODEC_ACM_OUTPUT;
                } 
        } 
        
        if (iIOAvail != (CODEC_ACM_OUTPUT|CODEC_ACM_INPUT)) {
                /* In theory we might be interested in codecs we can decode only. */
                return TRUE;
        }
        
        for(i = 0; i < ACM_MAX_DYNAMIC; i++) {
                if (!strcmp(known_codecs[i].szShortName, add.szShortName) &&
                        known_codecs[i].nSamplesPerSec == wfxPCM.nSamplesPerSec &&
                        known_codecs[i].nChannels == wfxPCM.nChannels &&
                        known_codecs[i].nAvgBytesPerSec == pafd->pwfx->nAvgBytesPerSec) {
                        /* This code is a little naive. */
                        known_codecs[i].status = CODEC_ACM_PRESENT;
                        known_codecs[i].had    = hadid;
                        memcpy(&known_codecs[i].wfx, &wfxDst, sizeof(WAVEFORMATEX));
                        printf("Added %s\n", known_codecs[i].szShortName);
                }
        }
        
        printf("\t\t%4.4lXH %4.4lXH, %s (%d Bps, Rate %d, align %d bytes, %d bits per sample, %d channels, cbsize %d)\n", pafd->dwFormatTag, pafd->dwFormatIndex, pafd->szFormat, pafd->pwfx->nAvgBytesPerSec, pafd->pwfx->nSamplesPerSec, pafd->pwfx->nBlockAlign, pafd->pwfx->wBitsPerSample, pafd->pwfx->nChannels, pafd->pwfx->cbSize); 
        
        switch(iType) {
        case CODEC_ACM_SAMPLE:
                printf("\t\t\tSample Based: ");
                break;
        case CODEC_ACM_FRAME:
                printf("\t\t\tFrame  Based: ");
                break;
        }
        printf("\t\t\tInput(%d) Output(%d) Samples per Frame(%d), Frame Size(%d)\n", 
                (iIOAvail&CODEC_ACM_INPUT) ? 1: 0,
                (iIOAvail&CODEC_ACM_OUTPUT) ? 1: 0,
                iSamplesPerFrame,
                iFrameSize);
                
        return TRUE;
}

static void
acmCodecCaps(HACMDRIVERID hadid)
{
        
        DWORD            dwSize;
        WAVEFORMATEX    *pwf;
        ACMFORMATDETAILS afd;
        
        add.cbStruct = sizeof(ACMDRIVERDETAILS);
        if (acmDriverDetails(hadid, &add, 0)) return; 
        printf("   Short name: %s\n", add.szShortName);
        printf("   Long name:  %s\n", add.szLongName);
        printf("   Copyright:  %s\n", add.szCopyright);
        printf("   Licensing:  %s\n", add.szLicensing);
        printf("   Features:   %s\n", add.szFeatures);
        printf("   Supports %u formats\n", add.cFormatTags);
        printf("   Supports %u filter formats\n", add.cFilterTags);
        
        if (acmDriverOpen(&hadActive, hadid, 0)) return;
        if (!acmMetrics((HACMOBJ)hadActive, ACM_METRIC_MAX_SIZE_FORMAT, &dwSize)){ 
                pwf = (WAVEFORMATEX*)xmalloc(dwSize);
                memset(pwf, 0, dwSize);
                pwf->cbSize     = LOWORD(dwSize) - sizeof(WAVEFORMATEX);
                pwf->wFormatTag = WAVE_FORMAT_UNKNOWN;
                memset(&afd,0,sizeof(ACMFORMATDETAILS));
                afd.cbStruct = sizeof(ACMFORMATDETAILS);
                afd.pwfx  = pwf;
                afd.cbwfx = dwSize;
                afd.dwFormatTag = WAVE_FORMAT_UNKNOWN;
                printf("\tInput Formats (suggested):\n");
                acmFormatEnum(hadActive, &afd, acmFormatEnumProc, 
                        ACM_FORMATENUMF_INPUT, 0);
                xfree(pwf);
        }
        acmDriverClose(hadActive,0);
}

BOOL CALLBACK 
acmDriverEnumProc(HACMDRIVERID hadid, DWORD dwInstance, DWORD fdwSupport)
{
        if (fdwSupport & ACMDRIVERDETAILS_SUPPORTF_CODEC) {
                acmCodecCaps(hadid);
        }
        
        return TRUE;
}

static HACMDRIVER*
acmGetDriverByID(HACMDRIVERID hid)
{
        int i;
        for(i = 0; i < nDrvOpen; i++) {
                if (hDrvID[i] == hid) return (hDrv + i);
        }
        return NULL;
}

static int
acmSecureDriver(HACMDRIVERID hid)
{
        if (acmGetDriverByID(hid) || 
            acmDriverOpen(&hDrv[nDrvOpen], hid, 0) == 0) {
                hDrvID[nDrvOpen] = hid;
                nDrvOpen++;
                return TRUE;
        }
        
        printf("Failed to open driver.\n");
        
        return FALSE;
}

static void
acmCodecsInit(void) 
{
        codec_t *cp;
        int i;

        for(i = 0; i < ACM_MAX_DYNAMIC; i++) {
                if (!known_codecs[i].status & CODEC_ACM_PRESENT ||
                        !acmSecureDriver(known_codecs[i].had))     {
                        cp = get_codec_by_pt(codec_matching(known_codecs[i].szRATCodecName,
                                                              known_codecs[i].nSamplesPerSec,
                                                              known_codecs[i].nChannels));
                        if (cp) {
                                disable_codec(cp);
                                printf("Disabled codec %s\n", cp->name);
                        }
                }
        }
}

void
acmStartup()
{
        DWORD dwCodecs = 0, dwDrivers = 0;
        
        acmMetrics(NULL, ACM_METRIC_COUNT_CODECS, &dwCodecs);
        acmMetrics(NULL, ACM_METRIC_COUNT_DRIVERS, &dwDrivers);
        printf("There are %d ACM codecs in %d drivers\n", dwCodecs, dwDrivers);
        acmDriverEnum(acmDriverEnumProc, 0L, 0L);
        acmCodecsInit();        
}

void
acmShutdown()
{
        int i, j, done;

        for (i = 0; i < nDrvOpen; i++) {
                done = FALSE;
                for(j = 0; j < i; j++) {
                        if (hDrvID[i] == hDrvID[j]) done = TRUE;
                }
                if (!done) {
                        acmDriverClose(hDrv[i], 0);
                }
        }
        nDrvOpen = 0;
}

static acm_codec_t *
acmMatchingCodec(codec_t *cp)
{
        int i;
        for(i = 0; i < ACM_MAX_DYNAMIC; i++) {
                if (!strcmp(cp->short_name, known_codecs[i].szRATCodecName) &&
                        known_codecs[i].status == CODEC_ACM_PRESENT) {
                        return known_codecs + i;
                }
        }
        return NULL;
}

typedef struct s_acm_state {
       HACMSTREAM   acms;
       WAVEFORMATEX *pwfx;
       codec_t     *cp;
       acm_codec_t *acp;
} acm_state_t;

acm_state_t * 
acmEncoderCreate(codec_t *cp)
{
        acm_codec_t *acp;
        acm_state_t *s;
        WAVEFORMATEX wfxRaw;
        HACMDRIVER  *phad;
        MMRESULT     mmr;

        assert(cp);
        acp = acmMatchingCodec(cp);
        if (!acp) return NULL;
        
        s = (acm_state_t*)xmalloc(sizeof(acm_state_t));        
        s->acms = NULL;
        /* Need to allocate WAVEFORMATEX with additional cbSize bytes for codec state */
        s->pwfx = (WAVEFORMATEX*)xmalloc(sizeof(WAVEFORMATEX) + acp->wfx.cbSize);
        memcpy(s->pwfx, &acp->wfx, sizeof(WAVEFORMATEX));

        wfxRaw.cbSize = 0;
        wfxRaw.nAvgBytesPerSec = cp->channels * cp->freq * cp->sample_size;
        wfxRaw.nBlockAlign     = cp->sample_size * cp->channels;
        wfxRaw.nChannels       = cp->channels;
        wfxRaw.nSamplesPerSec  = cp->freq;
        wfxRaw.wBitsPerSample  = cp->sample_size * 8;
        wfxRaw.wFormatTag      = WAVE_FORMAT_PCM;

        phad = acmGetDriverByID(acp->had);
        assert(phad);
        
        if ((mmr = acmStreamOpen(&s->acms, *phad, &wfxRaw, s->pwfx, NULL, 0L, 0L, 0L))) {
                printf("acmStreamOpen failed (%d)\n",mmr);
                xfree(s); 
                return NULL;
        }
        
        s->cp  = cp;
        s->acp = acp;

        return s;
}

void
acmEncode(struct s_acm_state *s, sample *src, struct s_coded_unit *dst)
{
        ACMSTREAMHEADER ash;
        MMRESULT mmr;

        int cbSrc, cbDst;

        assert(s);
        assert(s->acms);

        memset(&ash, 0, sizeof(ACMSTREAMHEADER));
        
        ash.cbStruct = sizeof(ACMSTREAMHEADER);    
        ash.pbSrc           = (u_char*) src;
        ash.cbSrcLength     = s->cp->unit_len * s->cp->sample_size;

        ash.pbDst           = dst->data;
        ash.cbDstLength     = dst->data_len;

        mmr = acmStreamSize(s->acms, ash.cbSrcLength, &cbDst, ACM_STREAMSIZEF_SOURCE);
        mmr = acmStreamSize(s->acms, ash.cbDstLength, &cbSrc, ACM_STREAMSIZEF_DESTINATION);

        if (mmr = acmStreamPrepareHeader(s->acms, &ash, 0)) {
                printf("acmStreamHeaderPrepare failed\n");
                return;
        }

        if (mmr = acmStreamConvert(s->acms, &ash, 0)) {
                printf("acmStreamConvert failed (%d)\n", mmr);
                switch(mmr) {
                case ACMERR_BUSY: 
                case ACMERR_UNPREPARED:
                case MMSYSERR_NOTSUPPORTED:
                case MMSYSERR_INVALFLAG:
                case MMSYSERR_INVALHANDLE:
                case MMSYSERR_INVALPARAM:
                default:
                        break;
                }
                return;
        }
        
        acmStreamUnprepareHeader(s->acms, &ash, 0);
}

void 
acmEncoderDestroy(struct s_acm_state *s)
{
        acmStreamClose(s->acms,0UL);
        xfree(s->pwfx);
        xfree(s);
        printf("Stream closed.\n");
}

#endif WIN32