subversion/libsvn_client/apply_edits.c

/*
 * apply_edits.c:  shared code for checkouts and updates
 *
 * ====================================================================
 * Copyright (c) 2000-2002 CollabNet.  All rights reserved.
 *
 * This software is licensed as described in the file COPYING, which
 * you should have received as part of this distribution.  The terms
 * are also available at http://subversion.tigris.org/license-1.html.
 * If newer versions of this license are posted there, you may use a
 * newer version instead, at your option.
 *
 * This software consists of voluntary contributions made by many
 * individuals.  For exact contribution history, see the revision
 * history and logs, available at http://subversion.tigris.org/.
 * ====================================================================
 */

/* ==================================================================== */



/*** Includes. ***/

#include <assert.h>
#include "svn_wc.h"
#include "svn_delta.h"
#include "svn_client.h"
#include "svn_string.h"
#include "svn_error.h"
#include "svn_path.h"
#include "client.h"



/*** Helpers ***/

static svn_error_t *
apply_delta (const svn_delta_editor_t *before_editor,
             void *before_edit_baton,
             const svn_delta_editor_t *after_editor,
             void *after_edit_baton,
             svn_stream_t *delta,
             svn_stringbuf_t *dest,
             svn_stringbuf_t *ancestor_path,    /* ignored if update */
             svn_revnum_t ancestor_revision,  /* ignored if update */
             svn_boolean_t recurse,
             apr_pool_t *pool,
             svn_boolean_t is_update)
{
  const svn_delta_editor_t *editor;
  void *edit_baton;
  const svn_delta_editor_t *wrap_editor;
  void *wrap_edit_baton;
  const svn_delta_edit_fns_t *wrapped_old_editor;
  void *wrapped_old_edit_baton;
  svn_error_t *err;

  /* If not given an ancestor path, we will (for the time being)
     simply create an empty one. */
  if (! ancestor_path)
    ancestor_path = svn_stringbuf_create ("", pool);
      
  if (is_update)
    {
      svn_stringbuf_t *anchor, *target;

      SVN_ERR (svn_wc_get_actual_target (dest, &anchor, &target, pool));
      err = svn_wc_get_update_editor (anchor,
                                      target,
                                      ancestor_revision,
                                      recurse,
                                      &editor,
                                      &edit_baton,
                                      pool);
    }
  else /* checkout */
    {
      err = svn_wc_get_checkout_editor (dest,
                                        ancestor_path,
                                        ancestor_revision,
                                        recurse,
                                        &editor,
                                        &edit_baton,
                                        pool);
    }
  if (err)
    return err;

  svn_delta_wrap_editor (&wrap_editor,
                         &wrap_edit_baton,
                         before_editor,
                         before_edit_baton,
                         editor,
                         edit_baton,
                         after_editor,
                         after_edit_baton,
                         pool);

  /* ### todo:  This is a TEMPORARY wrapper around our editor so we
     can use it with an old driver. */
  svn_delta_compat_wrap (&wrapped_old_editor, &wrapped_old_edit_baton, 
                         wrap_editor, wrap_edit_baton, pool);

  return svn_delta_xml_auto_parse (delta,
                                   wrapped_old_editor,
                                   wrapped_old_edit_baton,
                                   ancestor_path->data,
                                   ancestor_revision,
                                   pool);
}



static svn_error_t *
do_edits (const svn_delta_editor_t *before_editor,
          void *before_edit_baton,
          const svn_delta_editor_t *after_editor,
          void *after_edit_baton,
          svn_stringbuf_t *path,
          svn_stringbuf_t *xml_src,
          svn_stringbuf_t *URL,      /* ignored if update */
          svn_revnum_t revision,  /* ignored if update */
          svn_boolean_t recurse,
          apr_pool_t *pool,
          svn_boolean_t is_update)
{
  svn_error_t *err;
  apr_status_t apr_err;
  apr_file_t *in = NULL;

  assert (path != NULL);
  assert (xml_src != NULL);

  /* Open the XML source file. */
  apr_err = apr_file_open (&in, xml_src->data,
                      (APR_READ | APR_CREATE),
                      APR_OS_DEFAULT,
                      pool);
  if (apr_err)
    return svn_error_createf (apr_err, 0, NULL, pool,
                              "unable to open %s", xml_src->data);

  /* Check out the delta. */
  err = apply_delta (before_editor,
                     before_edit_baton,
                     after_editor,
                     after_edit_baton,
                     svn_stream_from_aprfile (in, pool),
                     path,
                     URL,
                     revision,
                     recurse,
                     pool,
                     is_update);
  if (err)
    {
      apr_file_close (in);
      return err;
    }

  apr_file_close (in);

  return SVN_NO_ERROR;
}



/*** Public Interfaces. ***/

svn_error_t *
svn_client__checkout_internal (const svn_delta_editor_t *before_editor,
                               void *before_edit_baton,
                               const svn_delta_editor_t *after_editor,
                               void *after_edit_baton,
                               svn_stringbuf_t *path,
                               svn_stringbuf_t *xml_src,
                               svn_stringbuf_t *URL,
                               svn_revnum_t revision,
                               svn_boolean_t recurse,
                               apr_pool_t *pool)
{
  return do_edits (before_editor, before_edit_baton,
                   after_editor, after_edit_baton,
                   path, xml_src, URL, revision, recurse,
                   pool, FALSE);
}


svn_error_t *
svn_client__update_internal (const svn_delta_editor_t *before_editor,
                             void *before_edit_baton,
                             const svn_delta_editor_t *after_editor,
                             void *after_edit_baton,
                             svn_stringbuf_t *path,
                             svn_stringbuf_t *xml_src,
                             svn_revnum_t ancestor_revision,
                             svn_boolean_t recurse,
                             apr_pool_t *pool)
{
  return do_edits (before_editor, before_edit_baton,
                   after_editor, after_edit_baton,
                   path, xml_src, NULL, ancestor_revision, recurse,
                   pool, TRUE);
}



/* 
 * local variables:
 * eval: (load-file "../../tools/dev/svn-dev.el")
 * end: */